public class PooledParallelSender extends PooledSender implements PooledParallelSenderMBean
| 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, setPoolSizegetAddress, 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, transferPropertiesclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetDirectBuffer, getInPoolSize, getInUsePoolSize, getKeepAliveCount, getKeepAliveTime, getMaxRetryAttempts, getMaxWait, getOoBInline, getPoolSize, getRxBufSize, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTcpNoDelay, getThrowOnFailedAck, getTimeout, getTxBufSize, getUdpRxBufSize, getUdpTxBufSize, isConnectedsetDirectBuffer, setMaxRetryAttemptsgetConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setRxBufSize, setTimeout, setTxBufSizeprotected static final StringManager sm
public void sendMessage(Member[] destination, ChannelMessage message) throws ChannelException
sendMessage in interface MultiPointSenderChannelExceptionpublic DataSender getNewDataSender()
getNewDataSender in class PooledSenderCopyright © 2000-2020 Apache Software Foundation. All Rights Reserved.