Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ConsumerThread(Session session,
Destination destination,
int threadNr) |
Modifier and Type | Method and Description |
---|---|
void |
browse() |
void |
consume() |
int |
getBatchSize() |
String |
getFilter() |
CountDownLatch |
getFinished() |
int |
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) |
ConsumerThread |
setMessageCount(int messageCount) |
ConsumerThread |
setReceiveTimeOut(int receiveTimeOut) |
ConsumerThread |
setRunning(boolean running) |
ConsumerThread |
setSleep(int sleep) |
ConsumerThread |
setVerbose(boolean verbose) |
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, int threadNr)
public void browse()
public void consume()
public int getReceived()
public boolean isDurable()
public ConsumerThread setDurable(boolean durable)
public ConsumerThread setMessageCount(int messageCount)
public ConsumerThread setBreakOnNull(boolean breakOnNull)
public int getBatchSize()
public ConsumerThread setBatchSize(int batchSize)
public int getMessageCount()
public boolean isBreakOnNull()
public int getReceiveTimeOut()
public ConsumerThread setReceiveTimeOut(int receiveTimeOut)
public boolean isRunning()
public ConsumerThread setRunning(boolean running)
public int getSleep()
public ConsumerThread setSleep(int sleep)
public CountDownLatch getFinished()
public ConsumerThread setFinished(CountDownLatch finished)
public boolean isBytesAsText()
public boolean isVerbose()
public ConsumerThread setVerbose(boolean verbose)
public ConsumerThread setBytesAsText(boolean bytesAsText)
public String getFilter()
public ConsumerThread setFilter(String filter)
public boolean isBrowse()
public ConsumerThread setBrowse(boolean browse)
Copyright © 2017 JBoss by Red Hat. All rights reserved.