org.apache.catalina.tribes.transport.nio
public class PooledParallelSender extends PooledSender implements MultiPointSender
Title:
Description:
Company:
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
connected |
| Constructor and Description |
|---|
PooledParallelSender() |
| Modifier and Type | Method and Description |
|---|---|
void |
connect()
connect
|
void |
disconnect()
disconnect
|
DataSender |
getNewDataSender() |
void |
sendMessage(Member[] destination,
ChannelMessage message) |
add, getInPoolSize, getInUsePoolSize, getPoolSize, getSender, keepalive, remove, returnSender, setPoolSizegetAddress, 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, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitadd, remove, setDirectBuffer, setMaxRetryAttempts, setRxBufSize, setTxBufSizegetConnectTime, getRequestCount, isConnected, keepalive, setKeepAliveCount, setKeepAliveTime, setTimeoutpublic void sendMessage(Member[] destination, ChannelMessage message) throws ChannelException
sendMessage in interface MultiPointSenderChannelExceptionpublic DataSender getNewDataSender()
getNewDataSender in class PooledSenderpublic void disconnect()
AbstractSenderdisconnect in interface DataSenderdisconnect in class PooledSenderpublic void connect()
throws java.io.IOException
AbstractSenderconnect in interface DataSenderconnect in class PooledSenderjava.io.IOExceptionCopyright © 2000-2013 Apache Software Foundation. All Rights Reserved.