Package ejava.examples.jmsnotifier
Class Publisher
- java.lang.Object
-
- ejava.examples.jmsnotifier.Publisher
-
-
Field Summary
Fields Modifier and Type Field Description protected ConnectionFactoryconnFactoryprotected intcountprotected Destinationdestinationprivate static org.slf4j.Loggerloggerprotected intmaxCountprotected Stringnameprotected Stringpasswordprotected longsleepTimeprotected booleanstartedprotected booleanstopprotected booleanstoppedprotected Stringusername
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclearMessages()private JMSContextcreateContext(Integer sessionMode)voidexecute()intgetCount()booleanisStarted()booleanisStopped()static voidmain(String[] args)voidrun()voidsetConnFactory(ConnectionFactory connFactory)voidsetDestination(Destination destination)voidsetMaxCount(int maxCount)voidsetPassword(String password)voidsetSleepTime(long sleepTime)voidsetUsername(String username)voidstop()
-
-
-
Field Detail
-
logger
private static final org.slf4j.Logger logger
-
connFactory
protected ConnectionFactory connFactory
-
destination
protected Destination destination
-
stop
protected boolean stop
-
stopped
protected boolean stopped
-
started
protected boolean started
-
count
protected int count
-
name
protected String name
-
sleepTime
protected long sleepTime
-
maxCount
protected int maxCount
-
username
protected String username
-
password
protected String password
-
-
Constructor Detail
-
Publisher
public Publisher(String name)
-
-
Method Detail
-
setConnFactory
public void setConnFactory(ConnectionFactory connFactory)
-
setDestination
public void setDestination(Destination destination)
-
getCount
public int getCount()
-
setSleepTime
public void setSleepTime(long sleepTime)
-
setMaxCount
public void setMaxCount(int maxCount)
-
clearMessages
public void clearMessages()
-
stop
public void stop()
-
isStopped
public boolean isStopped()
-
isStarted
public boolean isStarted()
-
setUsername
public void setUsername(String username)
-
setPassword
public void setPassword(String password)
-
createContext
private JMSContext createContext(Integer sessionMode)
-
main
public static void main(String[] args)
-
-