org.jgroups.protocols

Class TP.TransferQueueBundler

java.lang.Object

org.jgroups.protocols.TP.BaseBundler

org.jgroups.protocols.TP.TransferQueueBundler

All Implemented Interfaces:

java.lang.Runnable, TP.Bundler

Direct Known Subclasses:

TP.SimplifiedTransferQueueBundler

Enclosing class:

TP

protected class TP.TransferQueueBundler
extends TP.BaseBundler
implements java.lang.Runnable

This bundler adds all (unicast or multicast) messages to a queue until max size has been exceeded, but does send messages immediately when no other messages are available. https://issues.jboss.org/browse/JGRP-1540

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Thread	bundler_thread
protected java.util.concurrent.BlockingQueue<Message>	queue
protected static java.lang.String	THREAD_NAME

Fields inherited from class org.jgroups.protocols.TP.BaseBundler

output

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TransferQueueBundler(java.util.concurrent.BlockingQueue<Message> queue)
protected	TransferQueueBundler(int capacity)

Method Summary

Modifier and Type	Method and Description
int	getBufferSize()
java.lang.Thread	getThread()
void	run()
void	send(Message msg)
void	start()
void	stop()

Methods inherited from class org.jgroups.protocols.TP.BaseBundler

addMessage, numMessages, sendBundledMessages, sendMessageList, sendSingleMessage

Methods inherited from class java.lang.Object

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

Field Detail

queue

protected final java.util.concurrent.BlockingQueue<Message> queue

bundler_thread

protected volatile java.lang.Thread bundler_thread

THREAD_NAME

protected static final java.lang.String THREAD_NAME

See Also:

Constant Field Values

Constructor Detail

TransferQueueBundler

protected TransferQueueBundler(java.util.concurrent.BlockingQueue<Message> queue)

TransferQueueBundler

protected TransferQueueBundler(int capacity)

Method Detail

getThread

public java.lang.Thread getThread()

getBufferSize

public int getBufferSize()

start

public void start()

Specified by:

start in interface TP.Bundler

Overrides:

start in class TP.BaseBundler

stop

public void stop()

Specified by:

stop in interface TP.Bundler

Overrides:

stop in class TP.BaseBundler

send

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

Specified by:

send in interface TP.Bundler

Overrides:

send in class TP.BaseBundler

Throws:

java.lang.Exception

run

public void run()

Specified by:

run in interface java.lang.Runnable