public class ProducerThread extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected javax.jms.Session |
session |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ProducerThread(javax.jms.Session session,
javax.jms.Destination destination) |
Modifier and Type | Method and Description |
---|---|
protected javax.jms.Message |
createMessage(int i) |
CountDownLatch |
getFinished() |
String |
getMessage() |
int |
getMessageCount() |
int |
getMessageSize() |
String |
getMsgGroupID() |
long |
getMsgTTL() |
String |
getPayloadUrl() |
int |
getSentCount() |
int |
getSleep() |
int |
getTextMessageSize() |
int |
getTransactionBatchSize() |
boolean |
isPersistent() |
boolean |
isRunIndefinitely() |
boolean |
isRunning() |
void |
pauseProducer() |
void |
resetCounters() |
void |
resumeProducer() |
void |
run() |
void |
setFinished(CountDownLatch finished) |
void |
setMessage(String message) |
void |
setMessageCount(int messageCount) |
void |
setMessageSize(int messageSize) |
void |
setMsgGroupID(String msgGroupID) |
void |
setMsgTTL(long msgTTL) |
void |
setPayloadUrl(String payloadUrl) |
void |
setPersistent(boolean persistent) |
void |
setRunIndefinitely(boolean runIndefinitely) |
void |
setRunning(boolean running) |
void |
setSleep(int sleep) |
void |
setTextMessageSize(int textMessageSize) |
void |
setTransactionBatchSize(int transactionBatchSize) |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
protected javax.jms.Session session
public ProducerThread(javax.jms.Session session, javax.jms.Destination destination)
protected javax.jms.Message createMessage(int i) throws Exception
Exception
public void setMessageCount(int messageCount)
public int getSleep()
public void setSleep(int sleep)
public int getMessageCount()
public int getSentCount()
public boolean isPersistent()
public void setPersistent(boolean persistent)
public boolean isRunning()
public void setRunning(boolean running)
public long getMsgTTL()
public void setMsgTTL(long msgTTL)
public int getTransactionBatchSize()
public void setTransactionBatchSize(int transactionBatchSize)
public String getMsgGroupID()
public void setMsgGroupID(String msgGroupID)
public int getTextMessageSize()
public void setTextMessageSize(int textMessageSize)
public int getMessageSize()
public void setMessageSize(int messageSize)
public CountDownLatch getFinished()
public void setFinished(CountDownLatch finished)
public String getPayloadUrl()
public void setPayloadUrl(String payloadUrl)
public String getMessage()
public void setMessage(String message)
public boolean isRunIndefinitely()
public void setRunIndefinitely(boolean runIndefinitely)
public void pauseProducer()
public void resumeProducer()
public void resetCounters()
Copyright © 2005–2017. All rights reserved.