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
-
-
Field Summary
Fields Modifier and Type Field Description protected java.util.HashMap<Member,NioSender>
nioSenders
protected java.nio.channels.Selector
selector
protected long
selectTimeout
protected static StringManager
sm
-
Constructor Summary
Constructors Constructor Description ParallelNioSender()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
add(Member member)
Send to the specified member.void
connect()
Connect.void
disconnect()
Disconnect.protected void
finalize()
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 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, 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
-
-
-
-
Field Detail
-
sm
protected static final StringManager sm
-
selectTimeout
protected final long selectTimeout
- See Also:
- Constant Field Values
-
selector
protected final java.nio.channels.Selector selector
-
-
Method Detail
-
sendMessage
public void sendMessage(Member[] destination, ChannelMessage msg) throws ChannelException
Description copied from interface:MultiPointSender
Send the specified message.- Specified by:
sendMessage
in interfaceMultiPointSender
- Parameters:
destination
- the message destinationsmsg
- the data to send- Throws:
ChannelException
- if an error occurs
-
connect
public void connect()
Description copied from interface:DataSender
Connect.- Specified by:
connect
in interfaceDataSender
-
add
public void add(Member member)
Description copied from interface:MultiPointSender
Send to the specified member.- Specified by:
add
in interfaceMultiPointSender
- 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 interfaceMultiPointSender
- Parameters:
member
- the member
-
disconnect
public void disconnect()
Description copied from interface:DataSender
Disconnect.- Specified by:
disconnect
in interfaceDataSender
-
finalize
protected void finalize() throws java.lang.Throwable
- Overrides:
finalize
in classjava.lang.Object
- Throws:
java.lang.Throwable
-
keepalive
public boolean keepalive()
Description copied from interface:DataSender
Keepalive.- Specified by:
keepalive
in interfaceDataSender
- Overrides:
keepalive
in classAbstractSender
- Returns:
true
if kept alive
-
-