org.apache.catalina.tribes.transport.nio
public class PooledParallelSender extends PooledSender implements MultiPointSender
Title:
Description:
Company:
Modifier and Type | Field and Description |
---|---|
protected boolean |
connected |
Constructor and Description |
---|
PooledParallelSender() |
Modifier and Type | Method and Description |
---|---|
void |
connect()
connect
|
void |
disconnect()
disconnect
|
DataSender |
getNewDataSender() |
void |
sendMessage(Member[] destination,
ChannelMessage message) |
add, getInPoolSize, getInUsePoolSize, getPoolSize, getSender, keepalive, remove, returnSender, setPoolSize
getAddress, getAttempt, getConnectTime, getDestination, getDirect, getDirectBuffer, getKeepAliveCount, getKeepAliveTime, getMaxRetryAttempts, getOoBInline, getPort, getRequestCount, getRxBufSize, getSoKeepAlive, getSoLingerOn, getSoLingerTime, getSoReuseAddress, getSoTrafficClass, getTcpNoDelay, getThrowOnFailedAck, getTimeout, getTxBufSize, isConnected, setAddress, setAttempt, setConnected, setConnectTime, setDestination, setDirect, setDirectBuffer, setKeepAliveCount, setKeepAliveTime, setMaxRetryAttempts, setOoBInline, setPort, setRequestCount, setRxBufSize, setSoKeepAlive, setSoLingerOn, setSoLingerTime, setSoReuseAddress, setSoTrafficClass, setTcpNoDelay, setThrowOnFailedAck, setTimeout, setTxBufSize, transferProperties
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
add, remove, setDirectBuffer, setMaxRetryAttempts, setRxBufSize, setTxBufSize
getConnectTime, getRequestCount, isConnected, keepalive, setKeepAliveCount, setKeepAliveTime, setTimeout
public void sendMessage(Member[] destination, ChannelMessage message) throws ChannelException
sendMessage
in interface MultiPointSender
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
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.