org.apache.activemq.util

Class ProducerThread

java.lang.Object

java.lang.Thread

org.apache.activemq.util.ProducerThread

All Implemented Interfaces:

Runnable

public class ProducerThread
extends Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected Session	session

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ProducerThread(Session session, Destination destination)

Method Summary

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)

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

session

protected Session session

Constructor Detail

ProducerThread

public ProducerThread(Session session,
                      Destination destination)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

createMessage

protected Message createMessage(int i)
                         throws Exception

Throws:

Exception

setMessageCount

public void setMessageCount(int messageCount)

getSleep

public int getSleep()

setSleep

public void setSleep(int sleep)

getMessageCount

public int getMessageCount()

getSentCount

public int getSentCount()

isPersistent

public boolean isPersistent()

setPersistent

public void setPersistent(boolean persistent)

isRunning

public boolean isRunning()

setRunning

public void setRunning(boolean running)

getMsgTTL

public long getMsgTTL()

setMsgTTL

public void setMsgTTL(long msgTTL)

getTransactionBatchSize

public int getTransactionBatchSize()

setTransactionBatchSize

public void setTransactionBatchSize(int transactionBatchSize)

getMsgGroupID

public String getMsgGroupID()

setMsgGroupID

public void setMsgGroupID(String msgGroupID)

getTextMessageSize

public int getTextMessageSize()

setTextMessageSize

public void setTextMessageSize(int textMessageSize)

getMessageSize

public int getMessageSize()

setMessageSize

public void setMessageSize(int messageSize)

getFinished

public CountDownLatch getFinished()

setFinished

public void setFinished(CountDownLatch finished)

getPayloadUrl

public String getPayloadUrl()

setPayloadUrl

public void setPayloadUrl(String payloadUrl)

getMessage

public String getMessage()

setMessage

public void setMessage(String message)

isRunIndefinitely

public boolean isRunIndefinitely()

setRunIndefinitely

public void setRunIndefinitely(boolean runIndefinitely)

pauseProducer

public void pauseProducer()

resumeProducer

public void resumeProducer()

resetCounters

public void resetCounters()