org.jgroups.protocols

Class SenderSendsWithTimerBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

org.jgroups.protocols.SenderSendsWithTimerBundler

All Implemented Interfaces:

Runnable, Bundler

Deprecated.

@Deprecated
public class SenderSendsWithTimerBundler
extends BaseBundler
implements Runnable

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.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	MIN_NUMBER_OF_BUNDLING_TASKS Deprecated.
protected int	num_bundling_tasks Deprecated.

Fields inherited from class org.jgroups.protocols.BaseBundler

count, lock, log, msgs, output, transport

Constructor Summary

Constructors

Constructor and Description
SenderSendsWithTimerBundler() Deprecated.

Method Summary

Modifier and Type	Method and Description
void	run() Deprecated.
void	send(Message msg) Deprecated.
String	toString() Deprecated.

Methods inherited from class org.jgroups.protocols.BaseBundler

addMessage, init, numMessages, sendBundledMessages, sendMessageList, sendSingleMessage, start, stop

Methods inherited from class java.lang.Object

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

Field Detail

MIN_NUMBER_OF_BUNDLING_TASKS

protected static final int MIN_NUMBER_OF_BUNDLING_TASKS

Deprecated.

See Also:

Constant Field Values

num_bundling_tasks

protected int num_bundling_tasks

Deprecated.

Constructor Detail

SenderSendsWithTimerBundler

public SenderSendsWithTimerBundler()

Deprecated.

Method Detail

send

public void send(Message msg)
          throws Exception

Deprecated.

Specified by:

send in interface Bundler

Overrides:

send in class BaseBundler

Throws:

Exception

run

public void run()

Deprecated.

Specified by:

run in interface Runnable

toString

public String toString()

Deprecated.

Overrides:

toString in class Object