Package org.wso2.carbon.inbound.endpoint.protocol.mqtt

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

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()

Methods inherited from class java.lang.Object

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

Constructor Details

MqttConnectionConsumer

public MqttConnectionConsumer(org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions,
 org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttAsyncClient,
 MqttConnectionFactory confac,
 Properties mqttProperties,
 String name)

Method Details

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()