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

Class ConsumerThread

java.lang.Object

java.lang.Thread

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

All Implemented Interfaces:

Runnable

public class ConsumerThread
extends Thread

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	browse()
void	consume()
int	getBatchSize()
String	getFilter()
CountDownLatch	getFinished()
long	getMessageCount()
int	getReceived()
int	getReceiveTimeOut()
int	getSleep()
boolean	isBreakOnNull()
boolean	isBrowse()
boolean	isBytesAsText()
boolean	isDurable()
boolean	isRunning()
boolean	isVerbose()
void	run()
ConsumerThread	setBatchSize(int batchSize)
ConsumerThread	setBreakOnNull(boolean breakOnNull)
ConsumerThread	setBrowse(boolean browse)
ConsumerThread	setBytesAsText(boolean bytesAsText)
ConsumerThread	setDurable(boolean durable)
ConsumerThread	setFilter(String filter)
ConsumerThread	setFinished(CountDownLatch finished)
void	setListener(javax.jms.MessageListener listener)
ConsumerThread	setMessageCount(long messageCount)
ConsumerThread	setReceiveTimeOut(int receiveTimeOut)
ConsumerThread	setRunning(boolean running)
ConsumerThread	setSleep(int sleep)
ConsumerThread	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

Constructor Details

ConsumerThread

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

Method Details

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

browse

public void browse()

consume

public void consume()

getReceived

public int getReceived()

isDurable

public boolean isDurable()

setDurable

public ConsumerThread setDurable(boolean durable)

setMessageCount

public ConsumerThread setMessageCount(long messageCount)

setBreakOnNull

public ConsumerThread setBreakOnNull(boolean breakOnNull)

getBatchSize

public int getBatchSize()

setBatchSize

public ConsumerThread setBatchSize(int batchSize)

getMessageCount

public long getMessageCount()

isBreakOnNull

public boolean isBreakOnNull()

getReceiveTimeOut

public int getReceiveTimeOut()

setReceiveTimeOut

public ConsumerThread setReceiveTimeOut(int receiveTimeOut)

isRunning

public boolean isRunning()

setRunning

public ConsumerThread setRunning(boolean running)

getSleep

public int getSleep()

setSleep

public ConsumerThread setSleep(int sleep)

getFinished

public CountDownLatch getFinished()

setFinished

public ConsumerThread setFinished(CountDownLatch finished)

isBytesAsText

public boolean isBytesAsText()

isVerbose

public boolean isVerbose()

setVerbose

public ConsumerThread setVerbose(boolean verbose)

setBytesAsText

public ConsumerThread setBytesAsText(boolean bytesAsText)

getFilter

public String getFilter()

setFilter

public ConsumerThread setFilter(String filter)

isBrowse

public boolean isBrowse()

setBrowse

public ConsumerThread setBrowse(boolean browse)

setListener

public void setListener(javax.jms.MessageListener listener)