org.jgroups.protocols

Interface Bundler

All Known Implementing Classes:

BaseBundler, NoBundler, RingBufferBundler, RingBufferBundlerLockless, RingBufferBundlerLockless2, SenderSendsBundler, SenderSendsWithTimerBundler, SimplifiedTransferQueueBundler, TransferQueueBundler

public interface Bundler

Pluggable way to collect messages and send them as batches

Since:

4.0

Author:

Bela Ban

Method Summary

Modifier and Type	Method and Description
void	init(TP transport) Called after creation of the bundler
void	send(Message msg)
int	size() The number of unsent messages in the bundler
void	start() Called after init(TP)
void	stop()
void	viewChange(View view)

Method Detail

init

void init(TP transport)

Called after creation of the bundler

Parameters:

transport - the transport, for further reference

start

void start()

Called after init(TP)

stop

void stop()

send

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

Throws:

java.lang.Exception

viewChange

void viewChange(View view)

size

int size()

The number of unsent messages in the bundler