public class TransferQueueBundler extends BaseBundler implements Runnable
Modifier and Type | Field and Description |
---|---|
protected Thread |
bundler_thread |
protected BlockingQueue<Message> |
queue |
protected List<Message> |
remove_queue |
protected boolean |
running |
protected static String |
THREAD_NAME |
Modifier | Constructor and Description |
---|---|
|
TransferQueueBundler() |
protected |
TransferQueueBundler(BlockingQueue<Message> queue) |
|
TransferQueueBundler(int capacity) |
Modifier and Type | Method and Description |
---|---|
protected void |
_stop(boolean clear_queue) |
protected static int |
assertPositive(int value,
String message) |
int |
getBufferSize() |
Thread |
getThread() |
void |
init(TP transport)
Called after creation of the bundler
|
int |
removeQueueSize() |
TransferQueueBundler |
removeQueueSize(int size) |
void |
run() |
void |
send(Message msg) |
void |
start()
Called after
Bundler.init(TP) |
void |
stop() |
void |
stopAndFlush() |
addMessage, numMessages, sendBundledMessages, sendMessageList, sendSingleMessage
protected BlockingQueue<Message> queue
protected volatile Thread bundler_thread
protected volatile boolean running
protected static final String THREAD_NAME
public TransferQueueBundler()
protected TransferQueueBundler(BlockingQueue<Message> queue)
public TransferQueueBundler(int capacity)
public Thread getThread()
public int getBufferSize()
public int removeQueueSize()
public TransferQueueBundler removeQueueSize(int size)
public void init(TP transport)
Bundler
init
in interface Bundler
init
in class BaseBundler
transport
- the transport, for further referencepublic void start()
Bundler
Bundler.init(TP)
start
in interface Bundler
start
in class BaseBundler
public void stop()
stop
in interface Bundler
stop
in class BaseBundler
public void stopAndFlush()
public void send(Message msg) throws Exception
send
in interface Bundler
send
in class BaseBundler
Exception
protected void _stop(boolean clear_queue)
protected static int assertPositive(int value, String message)
Copyright © 2022 JBoss, a division of Red Hat. All rights reserved.