public interface  org.apache.activemq.transport.mqtt.MQTTTransport extends java.lang.Object
{
public abstract void sendToActiveMQ(org.apache.activemq.command.Command);
public abstract void sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame) throws java.io.IOException;
public abstract java.security.cert.X509Certificate[] getPeerCertificates();
public abstract void setPeerCertificates(java.security.cert.X509Certificate[]);
public abstract void onException(java.io.IOException);
public abstract org.apache.activemq.transport.mqtt.MQTTInactivityMonitor getInactivityMonitor();
public abstract org.apache.activemq.transport.mqtt.MQTTWireFormat getWireFormat();
public abstract void stop() throws java.lang.Exception;
}