org.apache.activemq.transport
Class AbstractInactivityMonitor
java.lang.Object
org.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.AbstractInactivityMonitor
- All Implemented Interfaces:
- Service, Transport, TransportListener
- Direct Known Subclasses:
- InactivityMonitor, StompInactivityMonitor
public abstract class AbstractInactivityMonitor
- extends TransportFilter
Used to make sure that commands are arriving periodically from the peer of
the transport.
Methods inherited from class org.apache.activemq.transport.TransportFilter |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
wireFormat
protected WireFormat wireFormat
AbstractInactivityMonitor
public AbstractInactivityMonitor(Transport next,
WireFormat wireFormat)
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface Service
- Overrides:
start
in class TransportFilter
- Throws:
java.lang.Exception
- See Also:
Service.start()
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
in class TransportFilter
- Throws:
java.lang.Exception
- See Also:
Service.stop()
processInboundWireFormatInfo
protected abstract void processInboundWireFormatInfo(WireFormatInfo info)
throws java.io.IOException
- Throws:
java.io.IOException
processOutboundWireFormatInfo
protected abstract void processOutboundWireFormatInfo(WireFormatInfo info)
throws java.io.IOException
- Throws:
java.io.IOException
onCommand
public void onCommand(java.lang.Object command)
- Description copied from interface:
TransportListener
- called to process a command
- Specified by:
onCommand
in interface TransportListener
- Overrides:
onCommand
in class TransportFilter
oneway
public void oneway(java.lang.Object o)
throws java.io.IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Specified by:
oneway
in interface Transport
- Overrides:
oneway
in class TransportFilter
- Throws:
java.io.IOException
onException
public void onException(java.io.IOException error)
- Description copied from interface:
TransportListener
- An unrecoverable exception has occured on the transport
- Specified by:
onException
in interface TransportListener
- Overrides:
onException
in class TransportFilter
setUseKeepAlive
public void setUseKeepAlive(boolean val)
getReadCheckTime
public long getReadCheckTime()
setReadCheckTime
public void setReadCheckTime(long readCheckTime)
getWriteCheckTime
public long getWriteCheckTime()
setWriteCheckTime
public void setWriteCheckTime(long writeCheckTime)
getInitialDelayTime
public long getInitialDelayTime()
setInitialDelayTime
public void setInitialDelayTime(long initialDelayTime)
isKeepAliveResponseRequired
public boolean isKeepAliveResponseRequired()
setKeepAliveResponseRequired
public void setKeepAliveResponseRequired(boolean value)
isMonitorStarted
public boolean isMonitorStarted()
startMonitorThreads
protected void startMonitorThreads()
throws java.io.IOException
- Throws:
java.io.IOException
configuredOk
protected abstract boolean configuredOk()
throws java.io.IOException
- Throws:
java.io.IOException
stopMonitorThreads
protected void stopMonitorThreads()
Copyright © 2005-2016. All Rights Reserved.