Package org.jgroups.protocols

Class AlternatingBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

org.jgroups.protocols.TransferQueueBundler

org.jgroups.protocols.AlternatingBundler

All Implemented Interfaces:

Runnable, Bundler

public class AlternatingBundler
extends TransferQueueBundler

Bundler implementation which sends message batches (or single messages) as soon as the target destination changes (or max_bundler_size would be exceeded).

Messages are removed from the main queue one by one and processed as follows:

A B B C C A causes the following sends: A -> {CC} -> {BB} -> A

Note that null is also a valid destination (send-to-all).

JIRA: https://issues.redhat.com/browse/JGRP-2171

Since:

4.0.4

Field Summary

Fields

Modifier and Type	Field	Description
protected final AverageMinMax	avg_batch_size
protected Address	target_dest
protected final List<Message>	target_list

Fields inherited from class org.jgroups.protocols.TransferQueueBundler

avg_fill_count, bundler_thread, drop_when_full, num_drops_on_full_queue, num_sends_because_full_queue, num_sends_because_no_msgs, queue, remove_queue, running, THREAD_NAME

Fields inherited from class org.jgroups.protocols.BaseBundler

avg_send_time, capacity, count, lock, log, max_size, msgs, output, transport

Constructor Summary

Constructors

Constructor	Description
AlternatingBundler()

Method Summary

Modifier and Type	Method	Description
protected void	_sendBundledMessages()
protected void	addMessage(Message msg, int size)
String	getAverageBatchSize()
void	resetStats()
void	run()

Methods inherited from class org.jgroups.protocols.TransferQueueBundler

addAndSendIfSizeExceeded, drain, dropWhenFull, dropWhenFull, getQueueSize, init, removeQueueSize, renameThread, send, size, start, stop

Methods inherited from class org.jgroups.protocols.BaseBundler

getCapacity, getMaxSize, sendBundledMessages, sendMessageList, sendSingleMessage, setCapacity, setMaxSize, viewChange

Methods inherited from class java.lang.Object

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

Field Details

target_dest

protected Address target_dest

target_list

protected final List<Message> target_list

avg_batch_size

protected final AverageMinMax avg_batch_size

Constructor Details

AlternatingBundler

public AlternatingBundler()

Method Details

getAverageBatchSize

public String getAverageBatchSize()

resetStats

public void resetStats()

Specified by:

resetStats in interface Bundler

Overrides:

resetStats in class TransferQueueBundler

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class TransferQueueBundler

_sendBundledMessages

protected void _sendBundledMessages()

addMessage

protected void addMessage(Message msg,
 int size)

Overrides:

addMessage in class BaseBundler