org.wso2.carbon.device.mgt.input.adapter.mqtt.util

Class MQTTAdapterListener

java.lang.Object

org.wso2.carbon.device.mgt.input.adapter.mqtt.util.MQTTAdapterListener

All Implemented Interfaces:

Runnable, org.eclipse.paho.client.mqttv3.MqttCallback

public class MQTTAdapterListener
extends Object
implements org.eclipse.paho.client.mqttv3.MqttCallback, Runnable

Constructor Summary

Constructors

Constructor and Description
MQTTAdapterListener(MQTTBrokerConnectionConfiguration mqttBrokerConnectionConfiguration, String topic, String mqttClientId, org.wso2.carbon.event.input.adapter.core.InputEventAdapterListener inputEventAdapterListener, int tenantId)

Method Summary

Methods

Modifier and Type	Method and Description
void	connectionLost(Throwable throwable)
void	createConnection()
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken)
boolean	isConnectionInitialized()
void	messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
void	run()
void	startListener()
void	stopListener(String adapterName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MQTTAdapterListener

public MQTTAdapterListener(MQTTBrokerConnectionConfiguration mqttBrokerConnectionConfiguration,
                   String topic,
                   String mqttClientId,
                   org.wso2.carbon.event.input.adapter.core.InputEventAdapterListener inputEventAdapterListener,
                   int tenantId)

Method Detail

startListener

public void startListener()
                   throws org.eclipse.paho.client.mqttv3.MqttException

Throws:

org.eclipse.paho.client.mqttv3.MqttException

stopListener

public void stopListener(String adapterName)

connectionLost

public void connectionLost(Throwable throwable)

Specified by:

connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallback

messageArrived

public void messageArrived(String topic,
                  org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
                    throws Exception

Specified by:

messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallback

Throws:

Exception

deliveryComplete

public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken)

Specified by:

deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback

run

public void run()

Specified by:

run in interface Runnable

createConnection

public void createConnection()

isConnectionInitialized

public boolean isConnectionInitialized()