|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.catalina.cluster.tcp.ClusterReceiverBase org.apache.catalina.cluster.tcp.SocketReplicationListener
Field Summary | |
protected static StringManager |
sm
The string manager for this package. |
Fields inherited from class org.apache.catalina.cluster.tcp.ClusterReceiverBase |
doListen, doReceivedProcessingStats, maxReceivedProcessingTime, minReceivedProcessingTime, receivedProcessingTime, totalReceivedBytes |
Constructor Summary | |
SocketReplicationListener()
|
Method Summary | |
protected java.net.ServerSocket |
createServerSocket()
create a Server Socket between tcpListenerPort and tcpListenMaxPort |
java.lang.String |
getInfo()
Return descriptive information about this implementation and the corresponding version number, in the format <description>/<version> . |
int |
getTcpListenMaxPort()
|
int |
getTcpListenTimeout()
|
protected void |
listen()
Master/Slave sender handling bind server socket to address and port |
void |
setTcpListenMaxPort(int maxListenPort)
|
void |
setTcpListenTimeout(int tcpListenTimeout)
|
void |
start()
Wait the createServerSocket find the correct socket port when default config is used. |
protected void |
stopListening()
Close serverSockets FIXME the channelSocket to connect own socket to terminate accpet loop! |
protected void |
unLockSocket()
Need to create a connection to unlock the ServerSocker#accept(). |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected static StringManager sm
Constructor Detail |
public SocketReplicationListener()
Method Detail |
public java.lang.String getInfo()
<description>/<version>
.
public int getTcpListenMaxPort()
public void setTcpListenMaxPort(int maxListenPort)
maxListenPort
- The tcpListenMaxPort to set.public int getTcpListenTimeout()
public void setTcpListenTimeout(int tcpListenTimeout)
tcpListenTimeout
- The tcpListenTimeout to set.public void start()
start
in interface ClusterReceiver
start
in class ClusterReceiverBase
ClusterReceiver.start()
,
createServerSocket()
protected void listen()
listen
in class ClusterReceiverBase
java.lang.Exception
protected java.net.ServerSocket createServerSocket()
protected void unLockSocket()
protected void stopListening()
stopListening
in class ClusterReceiverBase
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |