public class

MqttConnectorProcessAdapter

extends MqttConnectorLifecycleAdapter
implements ProcessAdapter<O>

java.lang.Object
↳	org.mule.modules.mqtt.MqttConnector
	↳	org.mule.modules.mqtt.adapters.MqttConnectorCapabilitiesAdapter
		↳	org.mule.modules.mqtt.adapters.MqttConnectorMetadataAdapater
			↳	org.mule.modules.mqtt.adapters.MqttConnectorLifecycleAdapter
				↳	org.mule.modules.mqtt.adapters.MqttConnectorProcessAdapter

Known Direct Subclasses

MqttConnectorConnectionIdentifierAdapter

Class Overview

A MqttConnectorProcessAdapter is a wrapper around MqttConnector that enables custom processing strategies.

Inherited Constants

From interface org.mule.api.lifecycle.Disposable

From interface org.mule.api.lifecycle.Initialisable

From interface org.mule.api.lifecycle.Startable

From interface org.mule.api.lifecycle.Stoppable

Inherited Fields

private static final Log	LOGGER
public static final MqttConnector.DeliveryQoS	MQTT_DEFAULT_QOS
private String	brokerServerUri	MQTT broker server URI.
private boolean	cleanSession	Clean Session.
private MqttClient	client
private String	clientId
private MqttConnectOptions	connectOptions
private int	connectionTimeout	Connection Timeout.
private int	keepAliveInterval	Keep-alive interval.
private String	lwtMessage	Last Will and Testimate message.
private int	lwtQos	Last Will and Testimate QOS.
private boolean	lwtRetained	Last Will and Testimate retention.
private String	lwtTopicName	Last Will and Testimate Topic
private MuleContext	muleContext
private String	password	Password to log into broker with.
private String	persistenceLocation	Directory on the machine where message persistence can be stored to disk.
private String	username	Username to log into broker with.