Package org.jgroups.protocols

Class NoBundler

java.lang.Object

org.jgroups.protocols.NoBundler

All Implemented Interfaces:

Bundler

Direct Known Subclasses:

AsyncNoBundler, BatchBundler

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

Field Summary

Fields

Modifier and Type	Field	Description
protected Log	log
protected TP	transport

Constructor Summary

Constructors

Constructor	Description
NoBundler()

Method Summary

Modifier and Type	Method	Description
int	getMaxSize()	Maximum number of bytes for messages to be queued until they are sent
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)
protected void	sendSingleMessage(Message msg, ByteArrayDataOutputStream output)
int	size()	The number of unsent messages in the bundler
void	start()	Called after Bundler.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

getCapacity, resetStats, setMaxSize, viewChange

Field Detail

transport

protected TP transport

log

protected Log log

Constructor Detail

NoBundler

public NoBundler()

Method Detail

size

public int size()

Description copied from interface: Bundler

The number of unsent messages in the bundler

Specified by:

size in interface Bundler

getMaxSize

public int getMaxSize()

Description copied from interface: Bundler

Maximum number of bytes for messages to be queued until they are sent

Specified by:

getMaxSize in interface Bundler

init

public void init(TP transport)

Description copied from interface: Bundler

Called after creation of the bundler

Specified by:

init in interface Bundler

Parameters:

transport - the transport, for further reference

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

start

public void start()

Description copied from interface: Bundler

Called after Bundler.init(TP)

Specified by:

start in interface Bundler

stop

public void stop()

Specified by:

stop in interface Bundler

send

public void send(Message msg)
          throws java.lang.Exception

Specified by:

send in interface Bundler

Throws:

java.lang.Exception

sendSingleMessage

protected void sendSingleMessage(Message msg,
                                 ByteArrayDataOutputStream output)
                          throws java.lang.Exception

Throws:

java.lang.Exception