org.springframework.integration.mqtt.inbound

Class MqttPahoMessageDrivenChannelAdapter

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.MessageProducerSupport

org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter

org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter

All Implemented Interfaces:

org.eclipse.paho.client.mqttv3.MqttCallback, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.SmartInitializingSingleton, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, ExpressionCapable, MessageProducer, NamedComponent, TrackableComponent

public class MqttPahoMessageDrivenChannelAdapter
extends AbstractMqttMessageDrivenChannelAdapter
implements org.eclipse.paho.client.mqttv3.MqttCallback, org.springframework.context.ApplicationEventPublisherAware

Eclipse Paho Implementation.

Since:

4.0

Author:

Gary Russell, Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_COMPLETION_TIMEOUT

Fields inherited from class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter

topicLock

Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

lifecycleCondition, lifecycleLock

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor and Description
MqttPahoMessageDrivenChannelAdapter(java.lang.String clientId, MqttPahoClientFactory clientFactory, java.lang.String... topic) Use this constructor if the server URI(s) are provided by the MqttConnectOptions.getServerURIs() provided by the MqttPahoClientFactory.
MqttPahoMessageDrivenChannelAdapter(java.lang.String url, java.lang.String clientId, MqttPahoClientFactory clientFactory, java.lang.String... topic) Use this constructor for a single url (although it may be overridden if the server URI(s) are provided by the MqttConnectOptions.getServerURIs() provided by the MqttPahoClientFactory).
MqttPahoMessageDrivenChannelAdapter(java.lang.String url, java.lang.String clientId, java.lang.String... topic) Use this URL when you don't need additional MqttConnectOptions.

Method Summary

Modifier and Type	Method and Description
void	addTopic(java.lang.String topic, int qos) Add a topic to the subscribed list.
void	connectionLost(java.lang.Throwable cause)
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
protected void	doStart() Takes no action by default.
protected void	doStop() Takes no action by default.
void	messageArrived(java.lang.String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
void	removeTopic(java.lang.String... topic) Remove a topic (or topics) from the subscribed list.
void	setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
void	setCompletionTimeout(long completionTimeout) Set the completion timeout for operations.
void	setRecoveryInterval(int recoveryInterval) The time (ms) to wait between reconnection attempts.

Methods inherited from class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter

addTopic, addTopics, getClientId, getComponentType, getConverter, getQos, getTopic, getUrl, onInit, setConverter, setQos

Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport

afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Field Detail

DEFAULT_COMPLETION_TIMEOUT

public static final long DEFAULT_COMPLETION_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

MqttPahoMessageDrivenChannelAdapter

public MqttPahoMessageDrivenChannelAdapter(java.lang.String url,
                                           java.lang.String clientId,
                                           MqttPahoClientFactory clientFactory,
                                           java.lang.String... topic)

Use this constructor for a single url (although it may be overridden if the server URI(s) are provided by the MqttConnectOptions.getServerURIs() provided by the MqttPahoClientFactory).

Parameters:

url - the URL.

clientId - The client id.

clientFactory - The client factory.

topic - The topic(s).

MqttPahoMessageDrivenChannelAdapter

public MqttPahoMessageDrivenChannelAdapter(java.lang.String clientId,
                                           MqttPahoClientFactory clientFactory,
                                           java.lang.String... topic)

Use this constructor if the server URI(s) are provided by the MqttConnectOptions.getServerURIs() provided by the MqttPahoClientFactory.

Parameters:

clientId - The client id.

clientFactory - The client factory.

topic - The topic(s).

Since:

4.1

MqttPahoMessageDrivenChannelAdapter

public MqttPahoMessageDrivenChannelAdapter(java.lang.String url,
                                           java.lang.String clientId,
                                           java.lang.String... topic)

Use this URL when you don't need additional MqttConnectOptions.

Parameters:

url - The URL.

clientId - The client id.

topic - The topic(s).

Method Detail

setCompletionTimeout

public void setCompletionTimeout(long completionTimeout)

Set the completion timeout for operations. Not settable using the namespace. Default 30000L milliseconds.

Parameters:

completionTimeout - The timeout.

Since:

4.1

setRecoveryInterval

public void setRecoveryInterval(int recoveryInterval)

The time (ms) to wait between reconnection attempts. Default .

Parameters:

recoveryInterval - the interval.

Since:

4.2.2

setApplicationEventPublisher

public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAware

Since:

4.2.2

doStart

protected void doStart()

Description copied from class: MessageProducerSupport

Takes no action by default. Subclasses may override this if they need lifecycle-managed behavior. Protected by 'lifecycleLock'.

Overrides:

doStart in class MessageProducerSupport

doStop

protected void doStop()

Description copied from class: MessageProducerSupport

Takes no action by default. Subclasses may override this if they need lifecycle-managed behavior.

Overrides:

doStop in class MessageProducerSupport

addTopic

public void addTopic(java.lang.String topic,
                     int qos)

Description copied from class: AbstractMqttMessageDrivenChannelAdapter

Add a topic to the subscribed list.

Overrides:

addTopic in class AbstractMqttMessageDrivenChannelAdapter

Parameters:

topic - The topic.

qos - The qos.

removeTopic

public void removeTopic(java.lang.String... topic)

Description copied from class: AbstractMqttMessageDrivenChannelAdapter

Remove a topic (or topics) from the subscribed list.

Overrides:

removeTopic in class AbstractMqttMessageDrivenChannelAdapter

Parameters:

topic - The topic.

connectionLost

public void connectionLost(java.lang.Throwable cause)

Specified by:

connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallback

messageArrived

public void messageArrived(java.lang.String topic,
                           org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)

Specified by:

messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallback

deliveryComplete

public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)

Specified by:

deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback