public class ProducerThread extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected Session |
session |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ProducerThread(Session session,
Destination destination) |
Modifier and Type | Method and Description |
---|---|
protected 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
public ProducerThread(Session session, Destination destination)
protected 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–2016 FuseSource, Corp.. All rights reserved.