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