public class MQTTInactivityMonitor extends TransportFilter
next, transportListener
Constructor and Description |
---|
MQTTInactivityMonitor(Transport next,
WireFormat wireFormat) |
Modifier and Type | Method and Description |
---|---|
long |
getInitialDelayTime() |
org.apache.activemq.transport.mqtt.MQTTProtocolConverter |
getProtocolConverter() |
long |
getReadCheckTime() |
boolean |
isKeepAliveResponseRequired() |
boolean |
isMonitorStarted() |
void |
onCommand(Object command)
called to process a command
|
void |
oneway(Object o)
A one way asynchronous send
|
void |
onException(IOException error)
An unrecoverable exception has occured on the transport
|
void |
setInitialDelayTime(long initialDelayTime) |
void |
setKeepAliveResponseRequired(boolean value) |
void |
setProtocolConverter(org.apache.activemq.transport.mqtt.MQTTProtocolConverter protocolConverter) |
void |
setReadCheckTime(long readCheckTime) |
void |
start() |
void |
stop() |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
public MQTTInactivityMonitor(Transport next, WireFormat wireFormat)
public void start() throws Exception
start
in interface Service
start
in class TransportFilter
Exception
Service.start()
public void stop() throws Exception
stop
in interface Service
stop
in class TransportFilter
Exception
Service.stop()
public void onCommand(Object command)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void oneway(Object o) throws IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
IOException
public void onException(IOException error)
TransportListener
onException
in interface TransportListener
onException
in class TransportFilter
public long getReadCheckTime()
public void setReadCheckTime(long readCheckTime)
public long getInitialDelayTime()
public void setInitialDelayTime(long initialDelayTime)
public boolean isKeepAliveResponseRequired()
public void setKeepAliveResponseRequired(boolean value)
public boolean isMonitorStarted()
public void setProtocolConverter(org.apache.activemq.transport.mqtt.MQTTProtocolConverter protocolConverter)
public org.apache.activemq.transport.mqtt.MQTTProtocolConverter getProtocolConverter()
Copyright © 2005–2017. All rights reserved.