public class MQTTInactivityMonitor extends TransportFilter
next, transportListener
Constructor and Description |
---|
MQTTInactivityMonitor(Transport next,
WireFormat wireFormat) |
Modifier and Type | Method and Description |
---|---|
MQTTProtocolConverter |
getProtocolConverter() |
long |
getReadGraceTime() |
long |
getReadKeepAliveTime() |
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 |
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, 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 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–2024 The Apache Software Foundation. All rights reserved.