org.jgroups.protocols
Class TP.TransferQueueBundler2

java.lang.Object
  org.jgroups.protocols.TP.TransferQueueBundler2

All Implemented Interfaces:

java.lang.Runnable, TP.Bundler

Enclosing class:

TP

protected class TP.TransferQueueBundler2
extends java.lang.Object
implements TP.Bundler, java.lang.Runnable

Similarly to DefaultBundler2, this bundler accumulates messages until max size or time have been exceeded, but does send individual messages immediately when no other messages are available. The difference to DefaultBundler2 is that we use a transfer queue and a bundler thread, whereas DefaultBundler2 makes the sender's thread send the accumulated messages.

Field Summary

static java.lang.String

THREAD_NAME

Method Summary

int	getBufferSize()
java.lang.Thread	getThread()
void	run()
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

Field Detail

THREAD_NAME

public static final java.lang.String THREAD_NAME

See Also:

Constant Field Values

Method Detail

start

public void start()

Specified by:

start in interface TP.Bundler

getThread

public java.lang.Thread getThread()

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

getBufferSize

public int getBufferSize()

run

public void run()

Specified by:

run in interface java.lang.Runnable