org.apache.activemq.transport.stomp
public class StompInactivityMonitor extends AbstractInactivityMonitor
wireFormat
next, transportListener
Constructor and Description |
---|
StompInactivityMonitor(Transport next,
WireFormat wireFormat) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
configuredOk() |
protected void |
processInboundWireFormatInfo(WireFormatInfo info) |
protected void |
processOutboundWireFormatInfo(WireFormatInfo info) |
void |
startMonitoring() |
getInitialDelayTime, getReadCheckTime, getWriteCheckTime, isKeepAliveResponseRequired, isMonitorStarted, onCommand, oneway, onException, setInitialDelayTime, setKeepAliveResponseRequired, setReadCheckTime, setUseKeepAlive, setWriteCheckTime, start, startMonitorThreads, stop, stopMonitorThreads
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
public StompInactivityMonitor(Transport next, WireFormat wireFormat)
public void startMonitoring() throws java.io.IOException
java.io.IOException
protected void processInboundWireFormatInfo(WireFormatInfo info) throws java.io.IOException
processInboundWireFormatInfo
in class AbstractInactivityMonitor
java.io.IOException
protected void processOutboundWireFormatInfo(WireFormatInfo info) throws java.io.IOException
processOutboundWireFormatInfo
in class AbstractInactivityMonitor
java.io.IOException
protected boolean configuredOk() throws java.io.IOException
configuredOk
in class AbstractInactivityMonitor
java.io.IOException
Copyright © 2005-2014. All Rights Reserved.