org.jgroups.protocols

Class TransferQueueBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

org.jgroups.protocols.TransferQueueBundler

All Implemented Interfaces:

Runnable, Bundler

Direct Known Subclasses:

SimplifiedTransferQueueBundler

public class TransferQueueBundler
extends BaseBundler
implements 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 Thread	bundler_thread
protected BlockingQueue<Message>	queue
protected List<Message>	remove_queue
protected boolean	running
protected static 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(BlockingQueue<Message> queue)
	TransferQueueBundler(int capacity)

Method Summary

Modifier and Type	Method and Description
protected void	_stop(boolean clear_queue)
protected static int	assertPositive(int value, String message)
int	getBufferSize()
Thread	getThread()
void	init(TP transport) Called after creation of the bundler
int	removeQueueSize()
TransferQueueBundler	removeQueueSize(int size)
void	run()
void	send(Message msg)
void	start() Called after Bundler.init(TP)
void	stop()
void	stopAndFlush()

Methods inherited from class org.jgroups.protocols.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 BlockingQueue<Message> queue

remove_queue

protected List<Message> remove_queue

bundler_thread

protected volatile Thread bundler_thread

running

protected volatile boolean running

THREAD_NAME

protected static final String THREAD_NAME

See Also:

Constant Field Values

Constructor Detail

TransferQueueBundler

public TransferQueueBundler()

TransferQueueBundler

protected TransferQueueBundler(BlockingQueue<Message> queue)

TransferQueueBundler

public TransferQueueBundler(int capacity)

Method Detail

getThread

public 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

stopAndFlush

public void stopAndFlush()

send

public void send(Message msg)
          throws Exception

Specified by:

send in interface Bundler

Overrides:

send in class BaseBundler

Throws:

Exception

run

public void run()

Specified by:

run in interface Runnable

_stop

protected void _stop(boolean clear_queue)

assertPositive

protected static int assertPositive(int value,
                                    String message)