public class PooledParallelSender extends PooledSender
Title:
Description:
Company:
Modifier and Type | Field and Description |
---|---|
protected boolean |
connected |
sm
Constructor and Description |
---|
PooledParallelSender() |
Modifier and Type | Method and Description |
---|---|
void |
connect()
connect
|
void |
disconnect()
disconnect
TODO Implement this org.apache.catalina.tribes.transport.DataSender method
|
DataSender |
getNewDataSender() |
void |
sendMessage(Member[] destination,
ChannelMessage message) |
add, getInPoolSize, getInUsePoolSize, getMaxWait, getPoolSize, getSender, keepalive, remove, returnSender, setMaxWait, setPoolSize
getAddress, getAttempt, getConnectTime, getDestination, getDirect, 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, setDirect, setDirectBuffer, setKeepAliveCount, setKeepAliveTime, setMaxRetryAttempts, setOoBInline, setPort, setRequestCount, setRxBufSize, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setTcpNoDelay, setThrowOnFailedAck, setTimeout, setTxBufSize, setUdpBased, setUdpPort, setUdpRxBufSize, setUdpTxBufSize, transferProperties
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setDirectBuffer, setMaxRetryAttempts
getConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setRxBufSize, setTimeout, setTxBufSize
public void sendMessage(Member[] destination, ChannelMessage message) throws ChannelException
ChannelException
public DataSender getNewDataSender()
getNewDataSender
in class PooledSender
public void disconnect()
AbstractSender
disconnect
in interface DataSender
disconnect
in class PooledSender
public void connect() throws IOException
AbstractSender
connect
in interface DataSender
connect
in class PooledSender
IOException
- TODO Implement this org.apache.catalina.tribes.transport.DataSender methodCopyright © 2000-2021 Apache Software Foundation. All Rights Reserved.