public abstract class BaseBundler extends Object implements Bundler
Modifier and Type | Field and Description |
---|---|
protected long |
count |
protected ReentrantLock |
lock |
protected Log |
log |
protected Map<Address,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) |
protected void |
clearMessages() |
void |
init(TP transport)
Called after creation of the bundler
|
void |
send(Message msg) |
protected void |
sendBundledMessages()
Sends all messages in the map.
|
protected void |
sendMessageList(Address dest,
Address src,
List<Message> list) |
protected void |
sendSingleMessage(Message msg) |
int |
size()
The number of unsent messages in the bundler
|
void |
start()
Called after
Bundler.init(TP) |
void |
stop() |
void |
viewChange(View view) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getStats, resetStats
protected final Map<Address,List<Message>> msgs
protected TP transport
protected final ReentrantLock lock
protected long count
protected ByteArrayDataOutputStream output
protected Log log
public void init(TP transport)
Bundler
public void start()
Bundler
Bundler.init(TP)
public void viewChange(View view)
viewChange
in interface Bundler
public int size()
Bundler
protected void sendBundledMessages()
protected void clearMessages()
protected void sendSingleMessage(Message msg)
protected void addMessage(Message msg, long size)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.