Package org.jgroups.protocols

Class SenderSendsBundler

java.lang.Object

org.jgroups.protocols.BaseBundler

org.jgroups.protocols.SenderSendsBundler

All Implemented Interfaces:

Bundler

public class SenderSendsBundler
extends BaseBundler

Since:

4.0

Author:

Bela Ban

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.atomic.AtomicInteger	num_senders

Fields inherited from class org.jgroups.protocols.BaseBundler

avg_fill_count, avg_remove_queue_size, avg_send_time, capacity, count, drop_when_full, FMT, 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, suppress_log, suppress_log_timeout, total_msgs_sent, transport, use_ringbuffer, use_single_sender_thread

Constructor Summary

Constructors

Constructor	Description
SenderSendsBundler()

Method Summary

Modifier and Type	Method	Description
void	send(Message msg)

Methods inherited from class org.jgroups.protocols.BaseBundler

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

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

destroy, renameThread

Field Detail

num_senders

protected final java.util.concurrent.atomic.AtomicInteger num_senders

Constructor Detail

SenderSendsBundler

public SenderSendsBundler()

Method Detail

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