Interface MQTTTransport
-
- All Known Implementing Classes:
AbstractMQTTSocket,MQTTSocket,MQTTTransportFilter
public interface MQTTTransportBasic interface that mediates between protocol converter and transport
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description MQTTInactivityMonitorgetInactivityMonitor()X509Certificate[]getPeerCertificates()MQTTWireFormatgetWireFormat()voidonException(IOException error)voidsendToActiveMQ(Command command)voidsendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command)voidsetPeerCertificates(X509Certificate[] certificates)voidstop()
-
-
-
Method Detail
-
sendToActiveMQ
void sendToActiveMQ(Command command)
-
sendToMQTT
void sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command) throws IOException- Throws:
IOException
-
getPeerCertificates
X509Certificate[] getPeerCertificates()
-
setPeerCertificates
void setPeerCertificates(X509Certificate[] certificates)
-
onException
void onException(IOException error)
-
getInactivityMonitor
MQTTInactivityMonitor getInactivityMonitor()
-
getWireFormat
MQTTWireFormat getWireFormat()
-
-