org.apache.activemq.transport.mqtt
public interface MQTTTransport
Modifier and Type | Method and Description |
---|---|
MQTTInactivityMonitor |
getInactivityMonitor() |
java.security.cert.X509Certificate[] |
getPeerCertificates() |
MQTTWireFormat |
getWireFormat() |
void |
onException(java.io.IOException error) |
void |
sendToActiveMQ(Command command) |
void |
sendToMQTT(MQTTFrame command) |
void |
stop() |
void sendToActiveMQ(Command command)
void sendToMQTT(MQTTFrame command) throws java.io.IOException
java.io.IOException
java.security.cert.X509Certificate[] getPeerCertificates()
void onException(java.io.IOException error)
MQTTInactivityMonitor getInactivityMonitor()
MQTTWireFormat getWireFormat()
void stop() throws java.lang.Exception
java.lang.Exception
Copyright © 2005-2014. All Rights Reserved.