Class MqttConnectionConsumer


  • public class MqttConnectionConsumer
    extends Object
    Connection consumer for MQTT listener which delegates connection attempts and subscription from the MQTT inbound listener
    • 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()
      • getMqttProperties

        public Properties getMqttProperties()
      • getName

        public String getName()