public class BaseBundler extends Object implements Bundler
Modifier and Type | Field and Description |
---|---|
protected long |
count |
protected ReentrantLock |
lock |
protected Log |
log |
protected Map<SingletonAddress,List<Message>> |
msgs
Keys are destinations, values are lists of Messages
|
protected ByteArrayDataOutputStream |
output |
protected TP |
transport |
Constructor and Description |
---|
BaseBundler() |
Modifier and Type | Method and Description |
---|---|
protected void |
addMessage(Message msg,
long size) |
void |
init(TP transport)
Called after creation of the bundler
|
protected int |
numMessages() |
void |
send(Message msg) |
protected void |
sendBundledMessages()
Sends all messages in the map.
|
protected void |
sendMessageList(Address dest,
Address src,
byte[] cluster_name,
List<Message> list) |
protected void |
sendSingleMessage(Message msg) |
void |
start()
Called after
Bundler.init(TP) |
void |
stop() |
protected final Map<SingletonAddress,List<Message>> msgs
protected TP transport
protected long count
protected final ReentrantLock lock
protected ByteArrayDataOutputStream output
protected Log log
public void init(TP transport)
Bundler
public void start()
Bundler
Bundler.init(TP)
protected void sendBundledMessages()
protected int numMessages()
protected void sendSingleMessage(Message msg)
protected void sendMessageList(Address dest, Address src, byte[] cluster_name, List<Message> list)
protected void addMessage(Message msg, long size)
Copyright © 2019 JBoss, a division of Red Hat. All rights reserved.