public class MQTTInactivityMonitor extends TransportFilter
next, transportListener
Constructor and Description |
---|
MQTTInactivityMonitor(Transport next,
org.apache.activemq.wireformat.WireFormat wireFormat) |
Modifier and Type | Method and Description |
---|---|
MQTTProtocolConverter |
getProtocolConverter() |
long |
getReadGraceTime() |
long |
getReadKeepAliveTime() |
void |
onCommand(Object command) |
void |
oneway(Object o) |
void |
onException(IOException error) |
void |
setProtocolConverter(MQTTProtocolConverter protocolConverter) |
void |
setReadGraceTime(long readGraceTime) |
void |
setReadKeepAliveTime(long readKeepAliveTime) |
void |
start() |
void |
startConnectChecker(long connectionTimeout) |
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, org.apache.activemq.wireformat.WireFormat wireFormat)
public void start() throws Exception
start
in interface org.apache.activemq.Service
start
in class TransportFilter
Exception
public void stop() throws Exception
stop
in interface org.apache.activemq.Service
stop
in class TransportFilter
Exception
public void onCommand(Object command)
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void oneway(Object o) throws IOException
oneway
in interface Transport
oneway
in class TransportFilter
IOException
public void onException(IOException error)
onException
in interface TransportListener
onException
in class TransportFilter
public long getReadGraceTime()
public void setReadGraceTime(long readGraceTime)
public long getReadKeepAliveTime()
public void setReadKeepAliveTime(long readKeepAliveTime)
public void setProtocolConverter(MQTTProtocolConverter protocolConverter)
public MQTTProtocolConverter getProtocolConverter()
public void startConnectChecker(long connectionTimeout)
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.