Package org.apache.catalina.tribes.transport.nio

Class PooledParallelSender

java.lang.Object

org.apache.catalina.tribes.transport.AbstractSender

org.apache.catalina.tribes.transport.PooledSender

org.apache.catalina.tribes.transport.nio.PooledParallelSender

All Implemented Interfaces:

DataSender, MultiPointSender, PooledParallelSenderMBean

public class PooledParallelSender
extends PooledSender
implements PooledParallelSenderMBean

A pooled sender that uses ParallelNioSender instances for parallel message delivery.

Field Summary

Fields

Modifier and Type	Field	Description
protected static StringManager	sm	StringManager for internationalized log messages.

Constructor Summary

Constructors

Constructor	Description
PooledParallelSender()	Creates a new PooledParallelSender instance.

Method Summary

Modifier and Type	Method	Description
DataSender	getNewDataSender()	Creates and returns a new DataSender instance for the pool.
void	sendMessage(Member[] destination, ChannelMessage message)	Send the specified message.

Methods inherited from class org.apache.catalina.tribes.transport.PooledSender

add, connect, disconnect, getInPoolSize, getInUsePoolSize, getMaxWait, getPoolSize, getSender, keepalive, remove, returnSender, setMaxWait, setPoolSize

Methods inherited from class org.apache.catalina.tribes.transport.AbstractSender

getAddress, getAttempt, getConnectTime, getDestination, getDirectBuffer, getKeepAliveCount, getKeepAliveTime, getMaxRetryAttempts, getOoBInline, getPort, getRequestCount, getRxBufSize, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTcpNoDelay, getThrowOnFailedAck, getTimeout, getTxBufSize, getUdpPort, getUdpRxBufSize, getUdpTxBufSize, isConnected, isUdpBased, setAddress, setAttempt, setConnected, setConnectTime, setDestination, setDirectBuffer, setKeepAliveCount, setKeepAliveTime, setMaxRetryAttempts, setOoBInline, setPort, setRequestCount, setRxBufSize, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setTcpNoDelay, setThrowOnFailedAck, setTimeout, setTxBufSize, setUdpBased, setUdpPort, setUdpRxBufSize, setUdpTxBufSize, transferProperties

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.catalina.tribes.transport.DataSender

getConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setRxBufSize, setTimeout, setTxBufSize

Methods inherited from interface org.apache.catalina.tribes.transport.MultiPointSender

setDirectBuffer, setMaxRetryAttempts

Methods inherited from interface org.apache.catalina.tribes.transport.nio.PooledParallelSenderMBean

getDirectBuffer, getInPoolSize, getInUsePoolSize, getKeepAliveCount, getKeepAliveTime, getMaxRetryAttempts, getMaxWait, getOoBInline, getPoolSize, getRxBufSize, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTcpNoDelay, getThrowOnFailedAck, getTimeout, getTxBufSize, getUdpRxBufSize, getUdpTxBufSize, isConnected

Field Detail

sm

protected static final StringManager sm

StringManager for internationalized log messages.

Constructor Detail

PooledParallelSender

public PooledParallelSender()

Creates a new PooledParallelSender instance.

Method Detail

sendMessage

public void sendMessage(Member[] destination,
                        ChannelMessage message)
                 throws ChannelException

Description copied from interface: MultiPointSender

Send the specified message.

Specified by:

sendMessage in interface MultiPointSender

Parameters:

destination - the message destinations

message - the data to send

Throws:

ChannelException - if an error occurs

getNewDataSender

public DataSender getNewDataSender()

Description copied from class: PooledSender

Creates and returns a new DataSender instance for the pool.

Specified by:

getNewDataSender in class PooledSender

Returns:

a new DataSender