org.apache.catalina.tribes.transport.nio
public class ParallelNioSender extends AbstractSender implements MultiPointSender
Title:
Description:
Company:
| Modifier and Type | Field and Description |
|---|---|
protected static Log |
log |
protected java.util.HashMap |
nioSenders |
protected java.nio.channels.Selector |
selector |
protected long |
selectTimeout |
| Constructor and Description |
|---|
ParallelNioSender() |
| Modifier and Type | Method and Description |
|---|---|
void |
add(Member member) |
void |
connect()
connect
|
void |
disconnect()
disconnect
|
void |
finalize() |
boolean |
keepalive()
keepalive
|
void |
remove(Member member) |
void |
sendMessage(Member[] destination,
ChannelMessage msg) |
getAddress, getAttempt, getConnectTime, getDestination, getDirect, getDirectBuffer, getKeepAliveCount, getKeepAliveTime, getMaxRetryAttempts, getOoBInline, getPort, getRequestCount, getRxBufSize, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTcpNoDelay, getThrowOnFailedAck, getTimeout, getTxBufSize, isConnected, setAddress, setAttempt, setConnected, setConnectTime, setDestination, setDirect, setDirectBuffer, setKeepAliveCount, setKeepAliveTime, setMaxRetryAttempts, setOoBInline, setPort, setRequestCount, setRxBufSize, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setTcpNoDelay, setThrowOnFailedAck, setTimeout, setTxBufSize, transferPropertiesclone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitsetDirectBuffer, setMaxRetryAttempts, setRxBufSize, setTxBufSizegetConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setTimeoutprotected static Log log
protected long selectTimeout
protected java.nio.channels.Selector selector
protected java.util.HashMap nioSenders
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()
finalize in class java.lang.Objectpublic boolean keepalive()
AbstractSenderkeepalive in interface DataSenderkeepalive in class AbstractSenderCopyright © 2000-2013 Apache Software Foundation. All Rights Reserved.