public class

SubscribeMessageSource

extends AbstractListeningMessageProcessor<O>
implements Runnable FlowConstructAware MuleContextAware Startable Stoppable MessageSource
java.lang.Object
   ↳ org.mule.modules.mqtt.processors.AbstractExpressionEvaluator
     ↳ org.mule.modules.mqtt.processors.AbstractConnectedProcessor
       ↳ org.mule.modules.mqtt.processors.AbstractMessageProcessor<O>
         ↳ org.mule.modules.mqtt.processors.AbstractListeningMessageProcessor<O>
           ↳ org.mule.modules.mqtt.sources.SubscribeMessageSource

Class Overview

SubscribeMessageSource wraps subscribe(java.lang.String, org.mule.modules.mqtt.MqttConnector.DeliveryQoS, java.util.List, org.mule.api.callback.SourceCallback) method in MqttConnector as a message source capable of generating Mule events. The POJO's method is invoked in its own thread.

Summary

[Expand]
Inherited Constants
From interface org.mule.api.lifecycle.Startable
From interface org.mule.api.lifecycle.Stoppable
Fields
protected String _clientIdType
protected MqttConnector.DeliveryQoS _qosType
protected String _topicFilterType
protected List<MqttTopicSubscription> _topicSubscriptionsType
protected Object clientId
protected Object qos
private Thread thread Thread under which this message source will execute
protected Object topicFilter
protected Object topicSubscriptions
[Expand]
Inherited Fields
From class org.mule.modules.mqtt.processors.AbstractListeningMessageProcessor
From class org.mule.modules.mqtt.processors.AbstractMessageProcessor
From class org.mule.modules.mqtt.processors.AbstractConnectedProcessor
Public Constructors
SubscribeMessageSource()
Public Methods
void initialise()
Obtains the expression manager from the Mule context and initialises the connector.
void run()
Implementation run() that will invoke the method on the pojo that this message source wraps.
void setClientId(Object value)
Sets clientId
void setQos(Object value)
Sets qos
void setTopicFilter(Object value)
Sets topicFilter
void setTopicSubscriptions(Object value)
Sets topicSubscriptions
void start()
Method to be called when Mule instance gets started.
void stop()
Method to be called when Mule instance gets stopped.
[Expand]
Inherited Methods
From class org.mule.modules.mqtt.processors.AbstractListeningMessageProcessor
From class org.mule.modules.mqtt.processors.AbstractMessageProcessor
From class org.mule.modules.mqtt.processors.AbstractConnectedProcessor
From class org.mule.modules.mqtt.processors.AbstractExpressionEvaluator
From class java.lang.Object
From interface java.lang.Runnable
From interface org.mule.api.callback.SourceCallback
From interface org.mule.api.construct.FlowConstructAware
From interface org.mule.api.context.MuleContextAware
From interface org.mule.api.lifecycle.Startable
From interface org.mule.api.lifecycle.Stoppable
From interface org.mule.api.source.MessageSource

Fields

protected String _clientIdType

protected MqttConnector.DeliveryQoS _qosType

protected String _topicFilterType

protected List<MqttTopicSubscription> _topicSubscriptionsType

protected Object clientId

protected Object qos

private Thread thread

Thread under which this message source will execute

protected Object topicFilter

protected Object topicSubscriptions

Public Constructors

public SubscribeMessageSource ()

Public Methods

public void initialise ()

Obtains the expression manager from the Mule context and initialises the connector. If a target object has not been set already it will search the Mule registry for a default one.

Throws
InitialisationException

public void run ()

Implementation run() that will invoke the method on the pojo that this message source wraps.

public void setClientId (Object value)

Sets clientId

Parameters
value Value to set

public void setQos (Object value)

Sets qos

Parameters
value Value to set

public void setTopicFilter (Object value)

Sets topicFilter

Parameters
value Value to set

public void setTopicSubscriptions (Object value)

Sets topicSubscriptions

Parameters
value Value to set

public void start ()

Method to be called when Mule instance gets started.

Throws
MuleException

public void stop ()

Method to be called when Mule instance gets stopped.

Throws
MuleException