public class

MqttTopicListener

extends Object
implements MqttCallback
java.lang.Object
   ↳ org.mule.modules.mqtt.MqttTopicListener

Class Overview

Topic Listener for the Mule MQTT Module.

Summary

Fields
private static final Log LOGGER
private final SourceCallback callback
private final MqttConnector connector
private final List<MqttTopicSubscription> subscriptions
Public Constructors
MqttTopicListener(MqttConnector connector, SourceCallback callback, List<MqttTopicSubscription> subscriptions)
Public Methods
void connect()
void connectionLost(Throwable throwable)
void deliveryComplete(MqttDeliveryToken mqttDeliveryToken)
void messageArrived(MqttTopic mqttTopic, MqttMessage mqttMessage)
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.eclipse.paho.client.mqttv3.MqttCallback

Fields

private static final Log LOGGER

private final SourceCallback callback

private final MqttConnector connector

private final List<MqttTopicSubscription> subscriptions

Public Constructors

public MqttTopicListener (MqttConnector connector, SourceCallback callback, List<MqttTopicSubscription> subscriptions)

Parameters
connector
callback
subscriptions

Public Methods

public void connect ()

Throws
ConnectionException

public void connectionLost (Throwable throwable)

Parameters
throwable

public void deliveryComplete (MqttDeliveryToken mqttDeliveryToken)

Parameters
mqttDeliveryToken

public void messageArrived (MqttTopic mqttTopic, MqttMessage mqttMessage)

Parameters
mqttTopic
mqttMessage
Throws
Exception