Interface MQTTTransport
-
- All Known Implementing Classes:
AbstractMQTTSocket
,MQTTSocket
,MQTTTransportFilter
public interface MQTTTransport
Basic interface that mediates between protocol converter and transport
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description MQTTInactivityMonitor
getInactivityMonitor()
X509Certificate[]
getPeerCertificates()
MQTTWireFormat
getWireFormat()
void
onException(IOException error)
void
sendToActiveMQ(Command command)
void
sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command)
void
setPeerCertificates(X509Certificate[] certificates)
void
stop()
-
-
-
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()
-
-