org.apache.activemq.transport.mqtt
Class MQTTInactivityMonitor
java.lang.Object
org.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.mqtt.MQTTInactivityMonitor
- All Implemented Interfaces:
- Service, Transport, TransportListener
public class MQTTInactivityMonitor
- extends TransportFilter
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 |
MQTTInactivityMonitor
public MQTTInactivityMonitor(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()
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
getReadCheckTime
public long getReadCheckTime()
setReadCheckTime
public void setReadCheckTime(long readCheckTime)
getInitialDelayTime
public long getInitialDelayTime()
setInitialDelayTime
public void setInitialDelayTime(long initialDelayTime)
isKeepAliveResponseRequired
public boolean isKeepAliveResponseRequired()
setKeepAliveResponseRequired
public void setKeepAliveResponseRequired(boolean value)
isMonitorStarted
public boolean isMonitorStarted()
setProtocolConverter
public void setProtocolConverter(org.apache.activemq.transport.mqtt.MQTTProtocolConverter protocolConverter)
getProtocolConverter
public org.apache.activemq.transport.mqtt.MQTTProtocolConverter getProtocolConverter()
Copyright © 2005-2016. All Rights Reserved.