Class MqttListener

  • All Implemented Interfaces:
    org.apache.synapse.inbound.InboundRequestProcessor

    public class MqttListener
    extends InboundOneTimeTriggerRequestProcessor
    This is the listener which directly interacts with the external MQTT server. Every MQTT inbound listener is bound to Server Port, Server Host, Client ID.
    • Field Detail

      • userName

        protected String userName
      • password

        protected String password
      • cleanSession

        protected boolean cleanSession
    • Constructor Detail

      • MqttListener

        public MqttListener​(org.apache.synapse.inbound.InboundProcessorParams params)
        constructor for the MQTT inbound endpoint listener *
        Parameters:
        params -
    • Method Detail

      • init

        public void init()
      • initAsyncClient

        public void initAsyncClient()
      • start

        public void start()
      • getName

        public String getName()
      • setName

        public void setName​(String name)