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,
String tenantDomain) |
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, org.wso2.carbon.event.input.adapter.core.InputEventAdapterConfiguration inputEventAdapterConfiguration, org.wso2.carbon.event.input.adapter.core.InputEventAdapterListener inputEventAdapterListener, String tenantDomain)
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.