public class ConsumerThread extends Thread
Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ConsumerThread(Session session,
Destination destination) |
Modifier and Type | Method and 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) |
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
public ConsumerThread(Session session, Destination destination)
public int getReceived()
public boolean isDurable()
public void setDurable(boolean durable)
public void setMessageCount(int messageCount)
public void setBreakOnNull(boolean breakOnNull)
public int getBatchSize()
public void setBatchSize(int batchSize)
public int getMessageCount()
public boolean isBreakOnNull()
public int getReceiveTimeOut()
public void setReceiveTimeOut(int receiveTimeOut)
public boolean isRunning()
public void setRunning(boolean running)
public int getSleep()
public void setSleep(int sleep)
public CountDownLatch getFinished()
public void setFinished(CountDownLatch finished)
public boolean isBytesAsText()
public void setBytesAsText(boolean bytesAsText)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.