DataSender
, MultiPointSender
, PooledParallelSenderMBean
public class PooledParallelSender extends PooledSender implements PooledParallelSenderMBean
Modifier and Type | Field | Description |
---|---|---|
protected static StringManager |
sm |
Constructor | Description |
---|---|
PooledParallelSender() |
Modifier and Type | Method | Description |
---|---|---|
DataSender |
getNewDataSender() |
|
void |
sendMessage(Member[] destination,
ChannelMessage message) |
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
getConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setRxBufSize, setTimeout, setTxBufSize
setDirectBuffer, setMaxRetryAttempts
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDirectBuffer, getInPoolSize, getInUsePoolSize, getKeepAliveCount, getKeepAliveTime, getMaxRetryAttempts, getMaxWait, getOoBInline, getPoolSize, getRxBufSize, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTcpNoDelay, getThrowOnFailedAck, getTimeout, getTxBufSize, getUdpRxBufSize, getUdpTxBufSize, isConnected
add, connect, disconnect, getInPoolSize, getInUsePoolSize, getMaxWait, getPoolSize, getSender, keepalive, remove, returnSender, setMaxWait, setPoolSize
protected static final StringManager sm
public void sendMessage(Member[] destination, ChannelMessage message) throws ChannelException
sendMessage
in interface MultiPointSender
ChannelException
public DataSender getNewDataSender()
getNewDataSender
in class PooledSender
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.