org.apache.catalina.tribes.transport
public abstract class PooledSender extends AbstractSender implements MultiPointSender
Title:
Description:
Company:
Constructor and Description |
---|
PooledSender() |
Modifier and Type | Method and Description |
---|---|
void |
add(Member member) |
void |
connect()
connect
|
void |
disconnect()
disconnect
|
int |
getInPoolSize() |
int |
getInUsePoolSize() |
abstract DataSender |
getNewDataSender() |
int |
getPoolSize() |
DataSender |
getSender() |
boolean |
keepalive()
keepalive
|
void |
remove(Member member) |
void |
returnSender(DataSender sender) |
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, 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
sendMessage, setDirectBuffer, setMaxRetryAttempts, setRxBufSize, setTxBufSize
getConnectTime, getRequestCount, isConnected, setKeepAliveCount, setKeepAliveTime, setTimeout
public abstract DataSender getNewDataSender()
public DataSender getSender()
public void returnSender(DataSender sender)
public void connect() throws java.io.IOException
AbstractSender
connect
in interface DataSender
connect
in class AbstractSender
java.io.IOException
public 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 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-2013 Apache Software Foundation. All Rights Reserved.