Class MqttConnectionConsumer
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.protocol.mqtt.MqttConnectionConsumer
-
public class MqttConnectionConsumer extends Object
Connection consumer for MQTT listener which delegates connection attempts and subscription from the MQTT inbound listener
-
-
Constructor Summary
Constructors Constructor Description MqttConnectionConsumer(org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions, org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttAsyncClient, MqttConnectionFactory confac, Properties mqttProperties, String name)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
execute()
org.eclipse.paho.client.mqttv3.MqttConnectOptions
getConnectOptions()
org.eclipse.paho.client.mqttv3.MqttAsyncClient
getMqttAsyncClient()
MqttConnectionFactory
getMqttConnectionFactory()
Properties
getMqttProperties()
String
getName()
void
shutdown()
-
-
-
Constructor Detail
-
MqttConnectionConsumer
public MqttConnectionConsumer(org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions, org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttAsyncClient, MqttConnectionFactory confac, Properties mqttProperties, String name)
-
-
Method Detail
-
execute
public void execute()
-
shutdown
public void shutdown()
-
getConnectOptions
public org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectOptions()
-
getMqttAsyncClient
public org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttAsyncClient()
-
getMqttConnectionFactory
public MqttConnectionFactory getMqttConnectionFactory()
-
getMqttProperties
public Properties getMqttProperties()
-
getName
public String getName()
-
-