Package org.jgroups.protocols

Class PerDestinationBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

org.jgroups.protocols.PerDestinationBundler

All Implemented Interfaces:

Bundler

public class PerDestinationBundler
extends BaseBundler

Queues messages per destination ('null' is a special destination). Uses 1 thread per destination to process queued messages, so it won't scale to many cluster members (unless virtual threads are used).
See https://issues.redhat.com/browse/JGRP-2639 for details.

Since:

5.2.7

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	PerDestinationBundler.SendBuffer

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.Map<Address,PerDestinationBundler.SendBuffer>	dests
protected Address	local_addr
protected static Address	NULL
protected static java.lang.String	THREAD_NAME

Fields inherited from class org.jgroups.protocols.BaseBundler

avg_fill_count, avg_remove_queue_size, avg_send_time, capacity, count, drop_when_full, FUNC, lock, log, max_size, msg_processing_policy, msg_stats, msgs, num_batches_sent, num_drops_on_full_queue, num_sends_because_full_queue, num_sends_because_no_msgs, num_single_msgs_sent, output, remove_queue_capacity, total_msgs_sent, transport

Constructor Summary

Constructors

Constructor	Description
PerDestinationBundler()

Method Summary

Modifier and Type	Method	Description
java.lang.String	dests()
java.lang.String	dump()
int	getQueueSize()	If the bundler has a queue and it should be managed by a queuing discipline (like Random Early Detection), then return the number of elements in the queue, else -1.
void	init(TP transport)	Called after creation of the bundler
void	send(Message msg)
int	size()	Returns the total number of messages in the hashmap
void	start()	Called after Bundler.init(TP)
void	stop()
void	viewChange(View view)

Methods inherited from class org.jgroups.protocols.BaseBundler

addMessage, avgBatchSize, dropWhenFull, dropWhenFull, getCapacity, getMaxSize, loopback, loopback, loopbackUnlessDontLoopbackIsSet, printBuffers, removeQueueCapacity, removeQueueCapacity, resetStats, sendBundledMessages, sendMessageList, sendMessageListArray, sendMultiple, sendMultiple, sendSingle, sendSingleMessage, setCapacity, setMaxSize

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgroups.protocols.Bundler

renameThread

Field Detail

local_addr

protected Address local_addr

dests

protected final java.util.Map<Address,PerDestinationBundler.SendBuffer> dests

NULL

protected static final Address NULL

THREAD_NAME

protected static final java.lang.String THREAD_NAME

See Also:

Constant Field Values

Constructor Detail

PerDestinationBundler

public PerDestinationBundler()

Method Detail

getQueueSize

public int getQueueSize()

Description copied from interface: Bundler

If the bundler has a queue and it should be managed by a queuing discipline (like Random Early Detection), then return the number of elements in the queue, else -1. In the latter case, the queue won't be managed.
This method needs to be fast as it might get called on every message to be sent.

Specified by:

getQueueSize in interface Bundler

Overrides:

getQueueSize in class BaseBundler

size

public int size()

Description copied from class: BaseBundler

Returns the total number of messages in the hashmap

Specified by:

size in interface Bundler

Overrides:

size in class BaseBundler

dump

public java.lang.String dump()

dests

public java.lang.String dests()

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

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

viewChange

public void viewChange(View view)

Specified by:

viewChange in interface Bundler

Overrides:

viewChange in class BaseBundler