org.apache.activemq.transport.mqtt
Interface MQTTTransport
- All Known Implementing Classes:
- MQTTTransportFilter
public interface MQTTTransport
Basic interface that mediates between protocol converter and transport
sendToActiveMQ
void sendToActiveMQ(Command command)
sendToMQTT
void sendToMQTT(MQTTFrame command)
throws java.io.IOException
- Throws:
java.io.IOException
getPeerCertificates
java.security.cert.X509Certificate[] getPeerCertificates()
onException
void onException(java.io.IOException error)
getInactivityMonitor
MQTTInactivityMonitor getInactivityMonitor()
getWireFormat
MQTTWireFormat getWireFormat()
stop
void stop()
throws java.lang.Exception
- Throws:
java.lang.Exception
Copyright © 2005-2016. All Rights Reserved.