Modifier and Type | Field and Description |
---|---|
protected ConnectionFactory |
connFactory |
protected int |
count |
protected Destination |
destination |
protected boolean |
durable |
private static org.apache.commons.logging.Log |
log |
protected int |
maxCount |
protected String |
name |
protected String |
password |
protected String |
selector |
protected long |
sleepTime |
protected boolean |
started |
protected boolean |
stop |
protected boolean |
stopped |
protected String |
username |
Constructor and Description |
---|
Subscriber(String name) |
Modifier and Type | Method and Description |
---|---|
void |
clearMessages() |
void |
execute() |
int |
getCount() |
boolean |
isStarted() |
boolean |
isStopped() |
static void |
main(String[] args) |
void |
run() |
void |
setConnFactory(ConnectionFactory connFactory) |
void |
setDestination(Destination destination) |
void |
setDurable(boolean durable) |
void |
setMaxCount(int maxCount) |
void |
setPassword(String password) |
void |
setSelector(String selector) |
void |
setSleepTime(long sleepTime) |
void |
setUsername(String username) |
void |
stop() |
private static final org.apache.commons.logging.Log log
protected ConnectionFactory connFactory
protected Destination destination
protected boolean stop
protected boolean stopped
protected boolean started
protected String name
protected int count
protected long sleepTime
protected int maxCount
protected boolean durable
protected String selector
protected String username
protected String password
public Subscriber(String name)
public void setConnFactory(ConnectionFactory connFactory)
public void setDestination(Destination destination)
public int getCount()
public void setSleepTime(long sleepTime)
public void setMaxCount(int maxCount)
public void setDurable(boolean durable)
public void setSelector(String selector)
public void clearMessages()
public void stop()
public boolean isStopped()
public boolean isStarted()
public void setUsername(String username)
public void setPassword(String password)
public static void main(String[] args)
Copyright © 2015 John's Hopkins University, Engineering Programs for Professionals. All rights reserved.