Package org.apache.activemq.util

Class ConsumerThread

java.lang.Object

java.lang.Thread

org.apache.activemq.util.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(Session session, Destination destination)

Method Summary

Modifier and Type	Method	Description
int	getBatchSize()
CountDownLatch	getFinished()
int	getMessageCount()
int	getReceived()
int	getReceiveTimeOut()
int	getSleep()
boolean	isBreakOnNull()
boolean	isBytesAsText()
boolean	isDurable()
boolean	isRunning()
void	run()
void	setBatchSize(int batchSize)
void	setBreakOnNull(boolean breakOnNull)
void	setBytesAsText(boolean bytesAsText)
void	setDurable(boolean durable)
void	setFinished(CountDownLatch finished)
void	setMessageCount(int messageCount)
void	setReceiveTimeOut(int receiveTimeOut)
void	setRunning(boolean running)
void	setSleep(int sleep)

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 Detail

ConsumerThread

public ConsumerThread(Session session,
                      Destination destination)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

getReceived

public int getReceived()

isDurable

public boolean isDurable()

setDurable

public void setDurable(boolean durable)

setMessageCount

public void setMessageCount(int messageCount)

setBreakOnNull

public void setBreakOnNull(boolean breakOnNull)

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

getMessageCount

public int getMessageCount()

isBreakOnNull

public boolean isBreakOnNull()

getReceiveTimeOut

public int getReceiveTimeOut()

setReceiveTimeOut

public void setReceiveTimeOut(int receiveTimeOut)

isRunning

public boolean isRunning()

setRunning

public void setRunning(boolean running)

getSleep

public int getSleep()

setSleep

public void setSleep(int sleep)

getFinished

public CountDownLatch getFinished()

setFinished

public void setFinished(CountDownLatch finished)

isBytesAsText

public boolean isBytesAsText()

setBytesAsText

public void setBytesAsText(boolean bytesAsText)