public class AlternatingBundler extends TransferQueueBundler implements DiagnosticsHandler.ProbeHandler
Modifier and Type | Field and Description |
---|---|
protected AverageMinMax |
avg_batch_size |
protected Address |
target_dest |
protected List<Message> |
target_list |
bundler_thread, fill_count, num_sends_because_full_queue, num_sends_because_no_msgs, queue, remove_queue, running, THREAD_NAME
Constructor and Description |
---|
AlternatingBundler() |
Modifier and Type | Method and Description |
---|---|
protected void |
_addMessage(Message msg,
long size) |
protected void |
_sendBundledMessages() |
Map<String,String> |
handleProbe(String... keys)
Handles a probe.
|
void |
run() |
void |
start()
Called after
Bundler.init(TP) |
void |
stop() |
String[] |
supportedKeys()
Returns a list of supported keys
|
assertPositive, getBufferSize, getStats, getThread, init, removeQueueSize, removeQueueSize, resetStats, send, size
addMessage, clearMessages, sendBundledMessages, sendMessageList, sendSingleMessage, viewChange
protected Address target_dest
protected final AverageMinMax avg_batch_size
public void start()
Bundler
Bundler.init(TP)
start
in interface Bundler
start
in class TransferQueueBundler
public void stop()
stop
in interface Bundler
stop
in class TransferQueueBundler
public void run()
run
in interface Runnable
run
in class TransferQueueBundler
public Map<String,String> handleProbe(String... keys)
DiagnosticsHandler.ProbeHandler
handleProbe
in interface DiagnosticsHandler.ProbeHandler
public String[] supportedKeys()
DiagnosticsHandler.ProbeHandler
supportedKeys
in interface DiagnosticsHandler.ProbeHandler
protected void _sendBundledMessages()
_sendBundledMessages
in class TransferQueueBundler
protected void _addMessage(Message msg, long size)
_addMessage
in class TransferQueueBundler
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.