|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.catalina.cluster.tcp.DataSender org.apache.catalina.cluster.tcp.PooledSocketSender
Send cluster messages with a pool of sockets (25). FIXME support processing stats
Field Summary |
Fields inherited from class org.apache.catalina.cluster.tcp.DataSender |
connectCounter, createTime, dataFailureCounter, dataResendCounter, disconnectCounter, doProcessingStats, doWaitAckStats, keepAliveConnectTime, keepAliveCount, maxProcessingTime, maxWaitAckTime, minProcessingTime, minWaitAckTime, missingAckCounter, nrOfRequests, processingTime, sm, totalBytes, waitAckTime |
Constructor Summary | |
PooledSocketSender(java.lang.String domain,
java.net.InetAddress host,
int port)
|
Method Summary | |
void |
connect()
Connect other cluster member receiver |
void |
disconnect()
disconnect and close socket |
java.lang.String |
getInfo()
Return descriptive information about this implementation and the corresponding version number, in the format <description>/<version> . |
int |
getInPoolSize()
|
int |
getInUsePoolSize()
|
int |
getMaxPoolSocketLimit()
|
void |
sendMessage(ClusterData data)
send message and use a pool of SocketSenders |
void |
setMaxPoolSocketLimit(int limit)
|
java.lang.String |
toString()
Name of this SockerSender |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public PooledSocketSender(java.lang.String domain, java.net.InetAddress host, int port)
domain
- replication cluster domain (session domain)host
- replication node tcp addressport
- replication node tcp portMethod Detail |
public java.lang.String getInfo()
<description>/<version>
.
getInfo
in class DataSender
public void setMaxPoolSocketLimit(int limit)
public int getMaxPoolSocketLimit()
public int getInPoolSize()
public int getInUsePoolSize()
public void connect() throws java.io.IOException
DataSender
connect
in interface IDataSender
connect
in class DataSender
java.io.IOException
IDataSender.connect()
public void disconnect()
DataSender
disconnect
in interface IDataSender
disconnect
in class DataSender
IDataSender.disconnect()
public void sendMessage(ClusterData data) throws java.io.IOException
sendMessage
in interface IDataSender
sendMessage
in class DataSender
data
- Message data
java.io.IOException
IDataSender.sendMessage(,
ClusterData)
public java.lang.String toString()
DataSender
toString
in class DataSender
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |