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 java.io.IOException
AbstractSender
connect
in interface DataSender
connect
in class PooledSender
java.io.IOException
- TODO Implement this org.apache.catalina.tribes.transport.DataSender methodCopyright © 2000-2015 Apache Software Foundation. All Rights Reserved.