Class NoBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

org.jgroups.protocols.NoBundler

All Implemented Interfaces:

Bundler

public class NoBundler
extends BaseBundler

Bundler which doesn't bundle :-) Can be used to measure the diff between bundling and non-bundling (e.g. at runtime). Not really meant for production.

Since:

4.0

Author:

Bela Ban

Field Summary

Fields inherited from class BaseBundler

avg_fill_count, avg_remove_queue_size, avg_send_time, capacity, count, drop_when_full, FMT, FUNC, lock, log, max_size, members, 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_delay, remove_queue_capacity, suppress_log, suppress_log_timeout, total_msgs_sent, transport, use_ringbuffer, use_single_sender_thread

Constructor Summary

Constructors

Constructor	Description
NoBundler()

Method Summary

Modifier and Type	Method	Description
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	send(Message msg)
int	size()	Returns the total number of messages in the hashmap

Methods inherited from class BaseBundler

addMessage, avgBatchSize, dropWhenFull, dropWhenFull, getCapacity, getMaxSize, init, loopback, loopback, loopbackUnlessDontLoopbackIsSet, printBuffers, removeDelay, removeDelay, removeQueueCapacity, removeQueueCapacity, resetStats, sendBundledMessages, sendMessageList, sendMultiple, sendSingle, sendSingleMessage, setCapacity, setMaxSize, start, stop, suppressLogTimeout, suppressLogTimeout, useRingBuffer, useRingBuffer, useSingleSenderThread, useSingleSenderThread, viewChange

Methods inherited from class Object

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

Methods inherited from interface Bundler

destroy, renameThread

Constructor Details

NoBundler

public NoBundler()

Method Details

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

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

send

public void send(Message msg)
          throws Exception

Specified by:

send in interface Bundler

Overrides:

send in class BaseBundler

Throws:

Exception