Package org.jgroups.protocols

Class AsyncNoBundler

java.lang.Object

org.jgroups.protocols.NoBundler

org.jgroups.protocols.AsyncNoBundler

All Implemented Interfaces:

Bundler

public class AsyncNoBundler
extends NoBundler

Simple and stupid async version of NoBundler. The main purpose is for a send() to return immediately, so delivery of a message which itself sends a message is fast.

Since:

4.0.4

Field Summary

Fields

Modifier and Type	Field	Description
protected int	max_threads
protected final ThreadPoolExecutor	thread_pool

Fields inherited from class org.jgroups.protocols.NoBundler

log, transport

Constructor Summary

Constructors

Constructor	Description
AsyncNoBundler()

Method Summary

Modifier and Type	Method	Description
void	send(Message msg)

Methods inherited from class org.jgroups.protocols.NoBundler

getMaxSize, getQueueSize, init, sendSingleMessage, size, start, 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, renameThread, resetStats, setMaxSize, viewChange

Field Details

max_threads

protected int max_threads

thread_pool

protected final ThreadPoolExecutor thread_pool

Constructor Details

AsyncNoBundler

public AsyncNoBundler()

Method Details

send

public void send(Message msg)
          throws Exception

Specified by:

send in interface Bundler

Overrides:

send in class NoBundler

Throws:

Exception