Class PerDestinationBundler.SendBuffer

java.lang.Object

org.jgroups.protocols.PerDestinationBundler.SendBuffer

All Implemented Interfaces:

Runnable

Enclosing class:

PerDestinationBundler

protected class PerDestinationBundler.SendBuffer
extends Object
implements Runnable

Since:

5.2.7

Author:

Bela Ban

Constructor Summary

Constructors

Constructor	Description
SendBuffer(Address dest)

Method Summary

Modifier and Type	Method	Description
protected void	addAndSendIfSizeExceeded(Message msg)
protected void	addMessage(Message msg, int size)
String	dump()
boolean	isThreadAlive()
protected void	removeAndSend(boolean execute_only_once)
void	run()
protected boolean	send(Message msg)
protected void	sendBundledMessages()
protected void	sendMessages(Address dest, Address src, List<Message> list)
protected int	size()
PerDestinationBundler.SendBuffer	start()
void	stop()
String	toString()

Methods inherited from class Object

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

Constructor Details

SendBuffer

public SendBuffer(Address dest)

Method Details

dump

public String dump()

isThreadAlive

public boolean isThreadAlive()

start

public PerDestinationBundler.SendBuffer start()

stop

public void stop()

run

public void run()

Specified by:

run in interface Runnable

removeAndSend

protected void removeAndSend(boolean execute_only_once)

addAndSendIfSizeExceeded

protected void addAndSendIfSizeExceeded(Message msg)

addMessage

protected void addMessage(Message msg,
 int size)

send

protected boolean send(Message msg)
                throws Exception

Throws:

Exception

sendBundledMessages

protected void sendBundledMessages()

sendMessages

protected void sendMessages(Address dest,
 Address src,
 List<Message> list)

toString

public String toString()

Overrides:

toString in class Object

size

protected int size()