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()
           
 X509Certificate[] getPeerCertificates()
           
 MQTTWireFormat getWireFormat()
           
 void onException(IOException error)
           
 void sendToActiveMQ(Command command)
           
 void sendToMQTT(org.fusesource.mqtt.codec.MQTTFrame command)
           
 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()

onException

void onException(IOException error)

getInactivityMonitor

MQTTInactivityMonitor getInactivityMonitor()

getWireFormat

MQTTWireFormat getWireFormat()

stop

void stop()
          throws Exception
Throws:
Exception


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.