public class ParallelNioSender extends AbstractSender implements MultiPointSender
| Modifier and Type | Field and Description |
|---|---|
protected java.util.HashMap<Member,NioSender> |
nioSenders |
protected java.nio.channels.Selector |
selector |
protected long |
selectTimeout |
protected static StringManager |
sm |
| Constructor and Description |
|---|
ParallelNioSender() |
| Modifier and Type | Method and Description |
|---|---|
void |
add(Member member) |
void |
connect()
connect
|
void |
disconnect()
disconnect
TODO Implement this org.apache.catalina.tribes.transport.DataSender method
|
void |
finalize() |
boolean |
keepalive()
keepalive
|
void |
remove(Member member) |
void |
sendMessage(Member[] destination,
ChannelMessage msg) |
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, transferPropertiesclone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitsetDirectBuffer, setMaxRetryAttemptsgetConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setRxBufSize, setTimeout, setTxBufSizeprotected static final StringManager sm
protected final long selectTimeout
protected final java.nio.channels.Selector selector
public ParallelNioSender()
throws java.io.IOException
java.io.IOExceptionpublic void sendMessage(Member[] destination, ChannelMessage msg) throws ChannelException
sendMessage in interface MultiPointSenderChannelExceptionpublic void connect()
AbstractSenderconnect in interface DataSenderconnect in class AbstractSenderpublic void add(Member member)
add in interface MultiPointSenderpublic void remove(Member member)
remove in interface MultiPointSenderpublic void disconnect()
AbstractSenderdisconnect in interface DataSenderdisconnect in class AbstractSenderpublic void finalize()
throws java.lang.Throwable
finalize in class java.lang.Objectjava.lang.Throwablepublic boolean keepalive()
AbstractSenderkeepalive in interface DataSenderkeepalive in class AbstractSenderCopyright © 2000-2018 Apache Software Foundation. All Rights Reserved.