Package org.jgroups.protocols
Class NoBundler
- java.lang.Object
-
- org.jgroups.protocols.NoBundler
-
- All Implemented Interfaces:
Bundler
- Direct Known Subclasses:
AsyncNoBundler
public class NoBundler extends java.lang.Object implements Bundler
Bundler which doesn't bundle :-) Can be used to measure the diff between bundling and non-bundling (e.g. at runtime) This bundler doesn't use a pool of buffers, but creates a new buffer every time a message is sent.- Since:
- 4.0
- Author:
- Bela Ban
-
-
Constructor Summary
Constructors Constructor Description NoBundler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
init(TP transport)
Called after creation of the bundlervoid
send(Message msg)
protected void
sendSingleMessage(Message msg, ByteArrayDataOutputStream output)
int
size()
The number of unsent messages in the bundlervoid
start()
Called afterBundler.init(TP)
void
stop()
-
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
getQueueSize, getStats, resetStats, viewChange
-
-
-
-
Method Detail
-
size
public int size()
Description copied from interface:Bundler
The number of unsent messages in the bundler
-
init
public void init(TP transport)
Description copied from interface:Bundler
Called after creation of the bundler
-
start
public void start()
Description copied from interface:Bundler
Called afterBundler.init(TP)
-
send
public void send(Message msg) throws java.lang.Exception
-
sendSingleMessage
protected void sendSingleMessage(Message msg, ByteArrayDataOutputStream output) throws java.lang.Exception
- Throws:
java.lang.Exception
-
-