Class PooledSender
java.lang.Object
org.apache.catalina.tribes.transport.AbstractSender
org.apache.catalina.tribes.transport.PooledSender
- All Implemented Interfaces:
DataSender
,MultiPointSender
- Direct Known Subclasses:
PooledParallelSender
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Send to the specified member.void
connect()
Connect.void
Disconnect.int
int
long
abstract DataSender
int
boolean
Keepalive.void
Stop sending to the specified member.void
returnSender
(DataSender sender) void
setMaxWait
(long maxWait) void
setPoolSize
(int poolSize) Methods inherited from class org.apache.catalina.tribes.transport.AbstractSender
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
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.catalina.tribes.transport.DataSender
getConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setRxBufSize, setTimeout, setTxBufSize
Methods inherited from interface org.apache.catalina.tribes.transport.MultiPointSender
sendMessage, setDirectBuffer, setMaxRetryAttempts
-
Field Details
-
sm
-
-
Constructor Details
-
PooledSender
public PooledSender()
-
-
Method Details
-
getNewDataSender
-
getSender
-
returnSender
-
connect
Description copied from interface:DataSender
Connect.- Specified by:
connect
in interfaceDataSender
- Throws:
IOException
- when an error occurs
-
disconnect
public void disconnect()Description copied from interface:DataSender
Disconnect.- Specified by:
disconnect
in interfaceDataSender
-
getInPoolSize
public int getInPoolSize() -
getInUsePoolSize
public int getInUsePoolSize() -
setPoolSize
public void setPoolSize(int poolSize) -
getPoolSize
public int getPoolSize() -
getMaxWait
public long getMaxWait() -
setMaxWait
public void setMaxWait(long maxWait) -
keepalive
public boolean keepalive()Description copied from interface:DataSender
Keepalive.- Specified by:
keepalive
in interfaceDataSender
- Overrides:
keepalive
in classAbstractSender
- Returns:
true
if kept alive
-
add
Description copied from interface:MultiPointSender
Send to the specified member.- Specified by:
add
in interfaceMultiPointSender
- Parameters:
member
- the member
-
remove
Description copied from interface:MultiPointSender
Stop sending to the specified member.- Specified by:
remove
in interfaceMultiPointSender
- Parameters:
member
- the member
-