org.jgroups.protocols

Class TP.BaseBundler

java.lang.Object

org.jgroups.protocols.TP.BaseBundler

All Implemented Interfaces:

TP.Bundler

Direct Known Subclasses:

TP.SenderSendsBundler, TP.SenderSendsWithTimerBundler, TP.TransferQueueBundler

Enclosing class:

TP

protected class TP.BaseBundler
extends java.lang.Object
implements TP.Bundler

Field Summary

Fields

Modifier and Type	Field and Description
protected ByteArrayDataOutputStream	output

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseBundler()

Method Summary

Modifier and Type	Method and Description
protected void	addMessage(Message msg, long size)
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, java.util.List<Message> list)
protected void	sendSingleMessage(Message msg)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

output

protected final ByteArrayDataOutputStream output

Constructor Detail

BaseBundler

protected BaseBundler()

Method Detail

start

public void start()

Specified by:

start in interface TP.Bundler

stop

public void stop()

Specified by:

stop in interface TP.Bundler

send

public void send(Message msg)
          throws java.lang.Exception

Specified by:

send in interface TP.Bundler

Throws:

java.lang.Exception

sendBundledMessages

protected void sendBundledMessages()

Sends all messages in the map. Messages for the same destination are bundled into a message list. The map will be cleared when done

numMessages

protected int numMessages()

sendSingleMessage

protected void sendSingleMessage(Message msg)

sendMessageList

protected void sendMessageList(Address dest,
                               Address src,
                               byte[] cluster_name,
                               java.util.List<Message> list)

addMessage

protected void addMessage(Message msg,
                          long size)