org.apache.activemq.transport.mqtt
Interface MQTTTransport

All Known Implementing Classes:
MQTTTransportFilter

public interface MQTTTransport

Basic interface that mediates between protocol converter and transport


Method Summary
 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()
           
 

Method Detail

sendToActiveMQ

void sendToActiveMQ(Command command)

sendToMQTT

void sendToMQTT(MQTTFrame command)
                throws java.io.IOException
Throws:
java.io.IOException

getPeerCertificates

java.security.cert.X509Certificate[] getPeerCertificates()

onException

void onException(java.io.IOException error)

getInactivityMonitor

MQTTInactivityMonitor getInactivityMonitor()

getWireFormat

MQTTWireFormat getWireFormat()

stop

void stop()
          throws java.lang.Exception
Throws:
java.lang.Exception


Copyright © 2005-2016. All Rights Reserved.