public interface MQTTTransport
Modifier and Type | Method and 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() |
void sendToActiveMQ(Command command)
void sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command) throws IOException
IOException
X509Certificate[] getPeerCertificates()
void setPeerCertificates(X509Certificate[] certificates)
void onException(IOException error)
MQTTInactivityMonitor getInactivityMonitor()
MQTTWireFormat getWireFormat()
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.