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 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) |
int |
size()
The number of unsent messages in the bundler
|
void |
start()
Called after
Bundler.init(TP) |
void |
stop() |
addMessage, checkForSharedTransport, clearMessages, sendBundledMessages, sendMessageList, sendSingleMessage, viewChange
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 int size()
Bundler
size
in interface Bundler
size
in class BaseBundler
public void send(Message msg) throws Exception
send
in interface Bundler
send
in class BaseBundler
Exception
protected static int assertPositive(int value, String message)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.