protected class TP.TransferQueueBundler extends Object implements TP.Bundler, Runnable
Modifier and Type | Field and Description |
---|---|
static String |
THREAD_NAME |
Modifier | Constructor and Description |
---|---|
protected |
TransferQueueBundler(int capacity) |
Modifier and Type | Method and Description |
---|---|
protected void |
addMessage(Message msg) |
protected void |
checkLength(long len) |
int |
getBufferSize() |
Thread |
getThread() |
void |
run() |
void |
send(Message msg) |
protected void |
sendBundledMessages(Map<SingletonAddress,List<Message>> msgs)
Sends all messages from the map, all messages for the same destination are bundled into 1 message.
|
protected void |
sendMessages() |
void |
start() |
void |
stop() |
public static final String THREAD_NAME
public void start()
start
in interface TP.Bundler
public Thread getThread()
public int getBufferSize()
public void stop()
stop
in interface TP.Bundler
public void send(Message msg) throws Exception
send
in interface TP.Bundler
Exception
protected void sendMessages()
protected void addMessage(Message msg)
protected void sendBundledMessages(Map<SingletonAddress,List<Message>> msgs)
msgs
- Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.