Package org.apache.activemq.transport.mqtt

Class MQTTInactivityMonitor

java.lang.Object

org.apache.activemq.transport.TransportFilter

org.apache.activemq.transport.mqtt.MQTTInactivityMonitor

All Implemented Interfaces:

org.apache.activemq.Service, org.apache.activemq.transport.Transport, org.apache.activemq.transport.TransportListener

public class MQTTInactivityMonitor
extends org.apache.activemq.transport.TransportFilter

Field Summary

Fields inherited from class org.apache.activemq.transport.TransportFilter

next, transportListener

Constructor Summary

Constructors

Constructor	Description
MQTTInactivityMonitor(org.apache.activemq.transport.Transport next, org.apache.activemq.wireformat.WireFormat wireFormat)

Method Summary

Modifier and Type	Method	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()

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

MQTTInactivityMonitor

public MQTTInactivityMonitor(org.apache.activemq.transport.Transport next,
 org.apache.activemq.wireformat.WireFormat wireFormat)

Method Details

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.activemq.Service

Overrides:

start in class org.apache.activemq.transport.TransportFilter

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.activemq.Service

Overrides:

stop in class org.apache.activemq.transport.TransportFilter

Throws:

Exception

onCommand

public void onCommand(Object command)

Specified by:

onCommand in interface org.apache.activemq.transport.TransportListener

Overrides:

onCommand in class org.apache.activemq.transport.TransportFilter

oneway

public void oneway(Object o)
            throws IOException

Specified by:

oneway in interface org.apache.activemq.transport.Transport

Overrides:

oneway in class org.apache.activemq.transport.TransportFilter

Throws:

IOException

onException

public void onException(IOException error)

Specified by:

onException in interface org.apache.activemq.transport.TransportListener

Overrides:

onException in class org.apache.activemq.transport.TransportFilter

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)