org.apache.activemq.artemis.cli.commands.util

Class ProducerThread

java.lang.Object

java.lang.Thread

org.apache.activemq.artemis.cli.commands.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, int threadNr)

Method Summary

Modifier and Type	Method and Description
protected Message	createMessage(int i, String threadName)
ReusableLatch	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()
boolean	isVerbose()
ProducerThread	pauseProducer()
ProducerThread	resetCounters()
ProducerThread	resumeProducer()
void	run()
ProducerThread	setFinished(int value)
ProducerThread	setMessage(String message)
ProducerThread	setMessageCount(int messageCount)
ProducerThread	setMessageSize(int messageSize)
ProducerThread	setMsgGroupID(String msgGroupID)
ProducerThread	setMsgTTL(long msgTTL)
ProducerThread	setPayloadUrl(String payloadUrl)
ProducerThread	setPersistent(boolean persistent)
ProducerThread	setRunIndefinitely(boolean runIndefinitely)
ProducerThread	setRunning(boolean running)
ProducerThread	setSleep(int sleep)
ProducerThread	setTextMessageSize(int textMessageSize)
ProducerThread	setTransactionBatchSize(int transactionBatchSize)
ProducerThread	setVerbose(boolean verbose)

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 final Session session

Constructor Detail

ProducerThread

public ProducerThread(Session session,
                      Destination destination,
                      int threadNr)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

createMessage

protected Message createMessage(int i,
                                String threadName)
                         throws Exception

Throws:

Exception

setMessageCount

public ProducerThread setMessageCount(int messageCount)

getSleep

public int getSleep()

setSleep

public ProducerThread setSleep(int sleep)

getMessageCount

public int getMessageCount()

getSentCount

public int getSentCount()

isPersistent

public boolean isPersistent()

setPersistent

public ProducerThread setPersistent(boolean persistent)

isRunning

public boolean isRunning()

setRunning

public ProducerThread setRunning(boolean running)

getMsgTTL

public long getMsgTTL()

setMsgTTL

public ProducerThread setMsgTTL(long msgTTL)

getTransactionBatchSize

public int getTransactionBatchSize()

setTransactionBatchSize

public ProducerThread setTransactionBatchSize(int transactionBatchSize)

getMsgGroupID

public String getMsgGroupID()

setMsgGroupID

public ProducerThread setMsgGroupID(String msgGroupID)

getTextMessageSize

public int getTextMessageSize()

setTextMessageSize

public ProducerThread setTextMessageSize(int textMessageSize)

getMessageSize

public int getMessageSize()

setMessageSize

public ProducerThread setMessageSize(int messageSize)

getFinished

public ReusableLatch getFinished()

setFinished

public ProducerThread setFinished(int value)

getPayloadUrl

public String getPayloadUrl()

setPayloadUrl

public ProducerThread setPayloadUrl(String payloadUrl)

getMessage

public String getMessage()

setMessage

public ProducerThread setMessage(String message)

isRunIndefinitely

public boolean isRunIndefinitely()

setRunIndefinitely

public ProducerThread setRunIndefinitely(boolean runIndefinitely)

pauseProducer

public ProducerThread pauseProducer()

resumeProducer

public ProducerThread resumeProducer()

resetCounters

public ProducerThread resetCounters()

isVerbose

public boolean isVerbose()

setVerbose

public ProducerThread setVerbose(boolean verbose)