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
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.transport.TransportFilter
next, transportListener
-
-
Constructor Summary
Constructors Constructor Description MQTTInactivityMonitor(Transport next, WireFormat wireFormat)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description MQTTProtocolConverter
getProtocolConverter()
long
getReadGraceTime()
long
getReadKeepAliveTime()
void
onCommand(Object command)
called to process a commandvoid
oneway(Object o)
A one way asynchronous sendvoid
onException(IOException error)
An unrecoverable exception has occured on the transportvoid
setProtocolConverter(MQTTProtocolConverter protocolConverter)
void
setReadGraceTime(long readGraceTime)
void
setReadKeepAliveTime(long readKeepAliveTime)
void
start()
void
startConnectChecker(long connectionTimeout)
void
stop()
-
Methods inherited from class org.apache.activemq.transport.TransportFilter
asyncRequest, getNext, getPeerCertificates, getReceiveCounter, getRemoteAddress, getTransportListener, getWireFormat, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setPeerCertificates, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
-
-
-
-
Constructor Detail
-
MQTTInactivityMonitor
public MQTTInactivityMonitor(Transport next, WireFormat wireFormat)
-
-
Method Detail
-
start
public void start() throws Exception
- Specified by:
start
in interfaceService
- Overrides:
start
in classTransportFilter
- Throws:
Exception
- See Also:
Service.start()
-
stop
public void stop() throws Exception
- Specified by:
stop
in interfaceService
- Overrides:
stop
in classTransportFilter
- Throws:
Exception
- See Also:
Service.stop()
-
onCommand
public void onCommand(Object command)
Description copied from interface:TransportListener
called to process a command- Specified by:
onCommand
in interfaceTransportListener
- Overrides:
onCommand
in classTransportFilter
-
oneway
public void oneway(Object o) throws IOException
Description copied from interface:Transport
A one way asynchronous send- Specified by:
oneway
in interfaceTransport
- Overrides:
oneway
in classTransportFilter
- Throws:
IOException
-
onException
public void onException(IOException error)
Description copied from interface:TransportListener
An unrecoverable exception has occured on the transport- Specified by:
onException
in interfaceTransportListener
- Overrides:
onException
in classTransportFilter
-
getReadGraceTime
public long getReadGraceTime()
-
setReadGraceTime
public void setReadGraceTime(long readGraceTime)
-
getReadKeepAliveTime
public long getReadKeepAliveTime()
-
setReadKeepAliveTime
public void setReadKeepAliveTime(long readKeepAliveTime)
-
setProtocolConverter
public void setProtocolConverter(MQTTProtocolConverter protocolConverter)
-
getProtocolConverter
public MQTTProtocolConverter getProtocolConverter()
-
startConnectChecker
public void startConnectChecker(long connectionTimeout)
-
-