public class MqttConnectionConsumer extends Object
Constructor and Description |
---|
MqttConnectionConsumer(org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions,
org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttAsyncClient,
MqttConnectionFactory confac,
Properties mqttProperties,
String name) |
Modifier and Type | Method and 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() |
public MqttConnectionConsumer(org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions, org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttAsyncClient, MqttConnectionFactory confac, Properties mqttProperties, String name)
public void execute()
public void shutdown()
public org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectOptions()
public org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttAsyncClient()
public MqttConnectionFactory getMqttConnectionFactory()
public Properties getMqttProperties()
public String getName()
Copyright © 2018 WSO2. All rights reserved.