org.jgroups.protocols

Class TP.DefaultBundler

java.lang.Object

org.jgroups.protocols.TP.DefaultBundler

All Implemented Interfaces:

TP.Bundler

Enclosing class:

TP

protected class TP.DefaultBundler
extends Object
implements TP.Bundler

The sender's thread adds a message to the hashmap and - if the accumulated size has been exceeded - sends all bundled messages. The cost of sending the bundled messages is therefore distributed over different threads; whoever happens to send a message exceeding the max size gets to send the accumulated messages. We also use a number of timer tasks to send bundled messages after a certain time has elapsed. This is necessary e.g. when a message is added that doesn't exceed the max size, but then no further messages are added, so elapsed time will trigger the sending, not exceeding of the max size.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultBundler()

Method Summary

Modifier and Type	Method and Description
void	send(Message msg)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBundler

protected DefaultBundler()

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 Exception

Specified by:

send in interface TP.Bundler

Throws:

Exception