Uses of Interface
org.jgroups.protocols.Bundler
-
Packages that use Bundler Package Description org.jgroups.protocols Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network. -
-
Uses of Bundler in org.jgroups.protocols
Classes in org.jgroups.protocols that implement Bundler Modifier and Type Class Description class
AlternatingBundler
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.jboss.org/browse/JGRP-2171class
AsyncNoBundler
Simple and stupid async version of NoBundler.class
BaseBundler
Implements storing of messages in a hashmap and sending of single messages and message batches.class
NoBundler
Bundler which doesn't bundle :-) Can be used to measure the diff between bundling and non-bundling (e.g.class
RemoveQueueBundler
Bundler implementation which sends message batches (or single messages) as soon as the remove queue is full (or max_bundler_size would be exceeded).
Messages are removed from the main queue and processed as follows (assuming they all fit into the remove queue):
A B B C C A causes the following sends: {AA} -> {CC} -> {BB}
Note that null is also a valid destination (send-to-all).
Contrary toTransferQueueBundler
, this bundler uses aRingBuffer
rather than an ArrayBlockingQueue and the size of the remove queue is fixed.class
RingBufferBundler
Bundler which usesRingBuffer
to store messages.class
RingBufferBundlerLockless
Bundler which doesn't use locks but relies on CAS.class
RingBufferBundlerLockless2
Lockless bundler using a reader thread which is unparked by (exactly one) writer thread.class
SenderSendsBundler
class
SimplifiedTransferQueueBundler
This bundler uses the same logic asTransferQueueBundler
but does not allocate memory except for the buffer itself and does not use complex data structures.class
TransferQueueBundler
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.Fields in org.jgroups.protocols declared as Bundler Modifier and Type Field Description protected Bundler
RED. bundler
protected Bundler
TP. bundler
Methods in org.jgroups.protocols that return Bundler Modifier and Type Method Description protected Bundler
TP. createBundler(java.lang.String type)
Bundler
TP. getBundler()
Methods in org.jgroups.protocols with parameters of type Bundler Modifier and Type Method Description <T extends TP>
TTP. setBundler(Bundler bundler)
Installs a bundler.
-