public abstract class PooledSender extends AbstractSender implements MultiPointSender
Modifier and Type | Field and Description |
---|---|
protected static StringManager |
sm |
Constructor and Description |
---|
PooledSender() |
Modifier and Type | Method and Description |
---|---|
void |
add(Member member) |
void |
connect()
connect
|
void |
disconnect()
disconnect
TODO Implement this org.apache.catalina.tribes.transport.DataSender method
|
int |
getInPoolSize() |
int |
getInUsePoolSize() |
long |
getMaxWait() |
abstract DataSender |
getNewDataSender() |
int |
getPoolSize() |
DataSender |
getSender() |
boolean |
keepalive()
keepalive
|
void |
remove(Member member) |
void |
returnSender(DataSender sender) |
void |
setMaxWait(long maxWait) |
void |
setPoolSize(int poolSize) |
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
sendMessage, setDirectBuffer, setMaxRetryAttempts
getConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setRxBufSize, setTimeout, setTxBufSize
protected static final StringManager sm
public abstract DataSender getNewDataSender()
public DataSender getSender()
public void returnSender(DataSender sender)
public void connect() throws IOException
AbstractSender
connect
in interface DataSender
connect
in class AbstractSender
IOException
- TODO Implement this org.apache.catalina.tribes.transport.DataSender methodpublic void disconnect()
AbstractSender
disconnect
in interface DataSender
disconnect
in class AbstractSender
public int getInPoolSize()
public int getInUsePoolSize()
public void setPoolSize(int poolSize)
public int getPoolSize()
public long getMaxWait()
public void setMaxWait(long maxWait)
public boolean keepalive()
AbstractSender
keepalive
in interface DataSender
keepalive
in class AbstractSender
public void add(Member member)
add
in interface MultiPointSender
public void remove(Member member)
remove
in interface MultiPointSender
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.