| Constructor and Description |
|---|
MQTTAdapterListener(MQTTBrokerConnectionConfiguration mqttBrokerConnectionConfiguration,
String topic,
org.wso2.carbon.event.input.adapter.core.InputEventAdapterConfiguration inputEventAdapterConfiguration,
org.wso2.carbon.event.input.adapter.core.InputEventAdapterListener inputEventAdapterListener) |
| 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() |
boolean |
startListener() |
void |
stopListener(String adapterName) |
public MQTTAdapterListener(MQTTBrokerConnectionConfiguration mqttBrokerConnectionConfiguration, String topic, org.wso2.carbon.event.input.adapter.core.InputEventAdapterConfiguration inputEventAdapterConfiguration, org.wso2.carbon.event.input.adapter.core.InputEventAdapterListener inputEventAdapterListener)
public boolean startListener()
throws org.eclipse.paho.client.mqttv3.MqttException
org.eclipse.paho.client.mqttv3.MqttExceptionpublic void stopListener(String adapterName)
public void connectionLost(Throwable throwable)
connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallbackpublic void messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) throws Exception
messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallbackExceptionpublic void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken)
deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallbackpublic void createConnection()
public boolean isConnectionInitialized()
Copyright © 2017 WSO2. All rights reserved.