org.apache.activemq.transport.mqtt
Class MQTTTransportFilter
java.lang.Object
org.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.mqtt.MQTTTransportFilter
- All Implemented Interfaces:
- Service, MQTTTransport, Transport, TransportListener
public class MQTTTransportFilter
- extends TransportFilter
- implements MQTTTransport
The MQTTTransportFilter normally sits on top of a TcpTransport that has been
configured with the StompWireFormat and is used to convert MQTT commands to
ActiveMQ commands. All of the conversion work is done by delegating to the
MQTTProtocolConverter
Methods inherited from class org.apache.activemq.transport.TransportFilter |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, start, stop, toString, transportInterupted, transportResumed, updateURIs |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
MQTTTransportFilter
public MQTTTransportFilter(Transport next,
WireFormat wireFormat,
BrokerContext brokerContext)
oneway
public void oneway(java.lang.Object o)
throws java.io.IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Specified by:
oneway
in interface Transport
- Overrides:
oneway
in class TransportFilter
- Throws:
java.io.IOException
onCommand
public void onCommand(java.lang.Object command)
- Description copied from interface:
TransportListener
- called to process a command
- Specified by:
onCommand
in interface TransportListener
- Overrides:
onCommand
in class TransportFilter
sendToActiveMQ
public void sendToActiveMQ(Command command)
- Specified by:
sendToActiveMQ
in interface MQTTTransport
sendToMQTT
public void sendToMQTT(MQTTFrame command)
throws java.io.IOException
- Specified by:
sendToMQTT
in interface MQTTTransport
- Throws:
java.io.IOException
getPeerCertificates
public java.security.cert.X509Certificate[] getPeerCertificates()
- Specified by:
getPeerCertificates
in interface MQTTTransport
isTrace
public boolean isTrace()
setTrace
public void setTrace(boolean trace)
getInactivityMonitor
public MQTTInactivityMonitor getInactivityMonitor()
- Specified by:
getInactivityMonitor
in interface MQTTTransport
setInactivityMonitor
public void setInactivityMonitor(MQTTInactivityMonitor monitor)
getWireFormat
public MQTTWireFormat getWireFormat()
- Specified by:
getWireFormat
in interface MQTTTransport
handleException
public void handleException(java.io.IOException e)
Copyright © 2005-2012. All Rights Reserved.