Class ParallelNioSender

java.lang.Object

org.apache.catalina.tribes.transport.AbstractSender

org.apache.catalina.tribes.transport.nio.ParallelNioSender

All Implemented Interfaces:

DataSender, MultiPointSender

public class ParallelNioSender
extends AbstractSender
implements MultiPointSender

A sender that sends messages to multiple members in parallel using NIO.

Field Summary

Fields

Modifier and Type	Field	Description
protected final long	selectTimeout	The timeout in milliseconds for the selector select operation.
protected static final StringManager	sm	The string manager for this package.

Constructor Summary

Constructors

Constructor	Description
ParallelNioSender()	Construct a new ParallelNioSender.

Method Summary

Modifier and Type	Method	Description
void	add(Member member)	Send to the specified member.
void	connect()	Connect.
void	disconnect()	Disconnect.
boolean	keepalive()	Keepalive.
void	remove(Member member)	Stop sending to the specified member.
void	sendMessage(Member[] destination, ChannelMessage msg)	Send the specified message.

Methods inherited from class 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 Object

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

Methods inherited from interface DataSender

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

Methods inherited from interface MultiPointSender

setDirectBuffer, setMaxRetryAttempts

Field Details

sm

protected static final StringManager sm

The string manager for this package.

selectTimeout

protected final long selectTimeout

The timeout in milliseconds for the selector select operation.

See Also:

• Constant Field Values

Constructor Details

ParallelNioSender

public ParallelNioSender()
                  throws IOException

Construct a new ParallelNioSender.

Throws:

IOException - If an I/O error occurs during initialization

Method Details

sendMessage

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

Description copied from interface: MultiPointSender

Send the specified message.

Specified by:

sendMessage in interface MultiPointSender

Parameters:

destination - the message destinations

msg - the data to send

Throws:

ChannelException - if an error occurs

connect

public void connect()

Description copied from interface: DataSender

Connect.

Specified by:

connect in interface DataSender

add

public void add(Member member)

Description copied from interface: MultiPointSender

Send to the specified member.

Specified by:

add in interface MultiPointSender

Parameters:

member - the member

remove

public void remove(Member member)

Description copied from interface: MultiPointSender

Stop sending to the specified member.

Specified by:

remove in interface MultiPointSender

Parameters:

member - the member

disconnect

public void disconnect()

Description copied from interface: DataSender

Disconnect.

Specified by:

disconnect in interface DataSender

keepalive

public boolean keepalive()

Description copied from interface: DataSender

Keepalive.

Specified by:

keepalive in interface DataSender

Overrides:

keepalive in class AbstractSender

Returns:

true if kept alive