org.jgroups.protocols

Class TransferQueueBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

org.jgroups.protocols.TransferQueueBundler

All Implemented Interfaces:

java.lang.Runnable, Bundler

Direct Known Subclasses:

SimplifiedTransferQueueBundler

public class TransferQueueBundler
extends 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 java.util.List<Message>	remove_queue
protected boolean	running
protected static java.lang.String	THREAD_NAME

Fields inherited from class org.jgroups.protocols.BaseBundler

count, lock, log, msgs, output, transport

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected static int	assertPositive(int value, java.lang.String message)
int	getBufferSize()
java.lang.Thread	getThread()
void	init(TP transport) Called after creation of the bundler
int	removeQueueSize()
TransferQueueBundler	removeQueueSize(int size)
void	run()
void	send(Message msg)
int	size() The number of unsent messages in the bundler
void	start() Called after Bundler.init(TP)
void	stop()

Methods inherited from class org.jgroups.protocols.BaseBundler

addMessage, checkForSharedTransport, clearMessages, sendBundledMessages, sendMessageList, sendSingleMessage, viewChange

Methods inherited from class java.lang.Object

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

Field Detail

queue

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

remove_queue

protected java.util.List<Message> remove_queue

bundler_thread

protected volatile java.lang.Thread bundler_thread

running

protected volatile boolean running

THREAD_NAME

protected static final java.lang.String THREAD_NAME

See Also:

Constant Field Values

Constructor Detail

TransferQueueBundler

public TransferQueueBundler()

TransferQueueBundler

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

TransferQueueBundler

public TransferQueueBundler(int capacity)

Method Detail

getThread

public java.lang.Thread getThread()

getBufferSize

public int getBufferSize()

removeQueueSize

public int removeQueueSize()

removeQueueSize

public TransferQueueBundler removeQueueSize(int size)

init

public void init(TP transport)

Description copied from interface: Bundler

Called after creation of the bundler

Specified by:

init in interface Bundler

Overrides:

init in class BaseBundler

Parameters:

transport - the transport, for further reference

start

public void start()

Description copied from interface: Bundler

Called after Bundler.init(TP)

Specified by:

start in interface Bundler

Overrides:

start in class BaseBundler

stop

public void stop()

Specified by:

stop in interface Bundler

Overrides:

stop in class BaseBundler

size

public int size()

Description copied from interface: Bundler

The number of unsent messages in the bundler

Specified by:

size in interface Bundler

Overrides:

size in class BaseBundler

send

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

Specified by:

send in interface Bundler

Overrides:

send in class BaseBundler

Throws:

java.lang.Exception

run

public void run()

Specified by:

run in interface java.lang.Runnable

assertPositive

protected static int assertPositive(int value,
                                    java.lang.String message)