Package org.apache.activemq.artemis.cli.commands.messages

Class ProducerThread

java.lang.Object

java.lang.Thread

org.apache.activemq.artemis.cli.commands.messages.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	Description
protected ActionContext	context
protected javax.jms.Session	session

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ProducerThread(javax.jms.Session session, javax.jms.Destination destination, int threadNr, ActionContext context)

Method Summary

Modifier and Type	Method	Description
protected void	applyProperties(javax.jms.Message message)
protected javax.jms.Message	createMessage(long i, String threadName)
ReusableLatch	getFinished()
String	getMessage()
long	getMessageCount()
int	getMessageSize()
String	getMsgGroupID()
long	getMsgTTL()
int	getObjectSize()
String	getPayloadUrl()
long	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(long messageCount)
ProducerThread	setMessageSize(int messageSize)
ProducerThread	setMsgGroupID(String msgGroupID)
ProducerThread	setMsgTTL(long msgTTL)
ProducerThread	setObjectSize(int objectSize)
ProducerThread	setPayloadUrl(String payloadUrl)
ProducerThread	setPersistent(boolean persistent)
ProducerThread	setProperties(String properties)
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, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, 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 javax.jms.Session session

context

protected final ActionContext context

Constructor Detail

ProducerThread

public ProducerThread(javax.jms.Session session,
                      javax.jms.Destination destination,
                      int threadNr,
                      ActionContext context)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

createMessage

protected javax.jms.Message createMessage(long i,
                                          String threadName)
                                   throws Exception

Throws:

Exception

applyProperties

protected void applyProperties(javax.jms.Message message)
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

setMessageCount

public ProducerThread setMessageCount(long messageCount)

getSleep

public int getSleep()

setSleep

public ProducerThread setSleep(int sleep)

getMessageCount

public long getMessageCount()

getSentCount

public long 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)

setProperties

public ProducerThread setProperties(String properties)

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)

getObjectSize

public int getObjectSize()

setObjectSize

public ProducerThread setObjectSize(int objectSize)