ConsumerThread |
ConsumerThread.setBatchSize(int batchSize) |
ConsumerThread |
ConsumerThread.setBreakOnNull(boolean breakOnNull) |
ConsumerThread |
ConsumerThread.setBrowse(boolean browse) |
ConsumerThread |
ConsumerThread.setBytesAsText(boolean bytesAsText) |
ConsumerThread |
ConsumerThread.setDurable(boolean durable) |
ConsumerThread |
ConsumerThread.setFilter(String filter) |
ConsumerThread |
ConsumerThread.setFinished(CountDownLatch finished) |
ConsumerThread |
ConsumerThread.setMessageCount(int messageCount) |
ConsumerThread |
ConsumerThread.setReceiveTimeOut(int receiveTimeOut) |
ConsumerThread |
ConsumerThread.setRunning(boolean running) |
ConsumerThread |
ConsumerThread.setSleep(int sleep) |
ConsumerThread |
ConsumerThread.setVerbose(boolean verbose) |