|
||||||||||
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.ReplicationListener
FIXME i18n log messages FIXME jmx support
Field Summary |
Fields inherited from class org.apache.catalina.cluster.tcp.ClusterReceiverBase |
doListen, doReceivedProcessingStats, log, maxReceivedProcessingTime, minReceivedProcessingTime, receivedProcessingTime, sm, totalReceivedBytes |
Constructor Summary | |
ReplicationListener()
|
Method Summary | |
java.lang.String |
getInfo()
Return descriptive information about this implementation and the corresponding version number, in the format <description>/<version> . |
java.lang.Object |
getInterestOpsMutex()
|
long |
getTcpSelectorTimeout()
|
int |
getTcpThreadCount()
|
protected void |
listen()
get data from channel and store in byte array send it to cluster |
protected void |
readDataFromSocket(java.nio.channels.SelectionKey key)
Sample data handler method for a channel with data ready to read. |
protected void |
registerChannel(java.nio.channels.Selector selector,
java.nio.channels.SelectableChannel channel,
int ops,
java.lang.Object attach)
Register the given channel with the given selector for the given operations of interest |
void |
setTcpSelectorTimeout(long tcpSelectorTimeout)
|
void |
setTcpThreadCount(int tcpThreadCount)
|
void |
start()
start cluster receiver |
protected void |
stopListening()
Close Selector. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public ReplicationListener()
Method Detail |
public java.lang.String getInfo()
<description>/<version>
.
public long getTcpSelectorTimeout()
public void setTcpSelectorTimeout(long tcpSelectorTimeout)
public int getTcpThreadCount()
public void setTcpThreadCount(int tcpThreadCount)
public java.lang.Object getInterestOpsMutex()
public void start()
start
in interface ClusterReceiver
start
in class ClusterReceiverBase
java.lang.Exception
ClusterReceiver.start()
protected void listen() throws java.lang.Exception
listen
in class ClusterReceiverBase
IOException
java.nio.channels.ClosedChannelException
java.lang.Exception
protected void stopListening()
stopListening
in class ClusterReceiverBase
ClusterReceiverBase.stopListening()
protected void registerChannel(java.nio.channels.Selector selector, java.nio.channels.SelectableChannel channel, int ops, java.lang.Object attach) throws java.lang.Exception
java.lang.Exception
protected void readDataFromSocket(java.nio.channels.SelectionKey key) throws java.lang.Exception
key
- A SelectionKey object associated with a channel
determined by the selector to be ready for reading. If the
channel returns an EOF condition, it is closed here, which
automatically invalidates the associated key. The selector
will then de-register the channel on the next select call.
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |