org.jgroups.protocols

Class NoBundler

java.lang.Object

org.jgroups.protocols.NoBundler

All Implemented Interfaces:

Bundler

public class NoBundler
extends Object
implements Bundler

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

Since:

3.6.10

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	NoBundler.Output

Field Summary

Fields

Modifier and Type	Field and Description
protected ReentrantLock	lock
protected Log	log
protected ByteArrayDataOutputStream	output
protected TP	transport

Constructor Summary

Constructors

Constructor and Description
NoBundler()

Method Summary

Modifier and Type	Method and Description
void	init(TP transport) Called after creation of the bundler
void	send(Message msg)
protected void	sendSingleMessage(Message msg, ByteArrayDataOutputStream output)
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

Field Detail

transport

protected TP transport

lock

protected final ReentrantLock lock

log

protected Log log

output

protected final ByteArrayDataOutputStream output

Constructor Detail

NoBundler

public NoBundler()

Method Detail

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

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 Exception

Specified by:

send in interface Bundler

Throws:

Exception

sendSingleMessage

protected void sendSingleMessage(Message msg,
                                 ByteArrayDataOutputStream output)