public class PooledParallelSender extends PooledSender
Modifier and Type | Field and Description |
---|---|
protected static StringManager |
sm |
Constructor and Description |
---|
PooledParallelSender() |
Modifier and Type | Method and Description |
---|---|
DataSender |
getNewDataSender() |
void |
sendMessage(Member[] destination,
ChannelMessage message) |
add, connect, disconnect, getInPoolSize, getInUsePoolSize, getMaxWait, getPoolSize, getSender, keepalive, remove, returnSender, setMaxWait, setPoolSize
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, transferProperties
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setDirectBuffer, setMaxRetryAttempts
getConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setRxBufSize, setTimeout, setTxBufSize
protected static final StringManager sm
public void sendMessage(Member[] destination, ChannelMessage message) throws ChannelException
ChannelException
public DataSender getNewDataSender()
getNewDataSender
in class PooledSender
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.