org.springframework.integration.mqtt.outbound

Class MqttPahoMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler

org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler

All Implemented Interfaces:

org.eclipse.paho.client.mqttv3.MqttCallback, org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware, org.springframework.context.Lifecycle, org.springframework.core.Ordered, ExpressionCapable, Orderable, NamedComponent, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageHandlerMetrics, TrackableComponent, org.springframework.messaging.MessageHandler, reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>

public class MqttPahoMessageHandler
extends AbstractMqttMessageHandler
implements org.eclipse.paho.client.mqttv3.MqttCallback, org.springframework.context.ApplicationEventPublisherAware

Eclipse Paho implementation.

Since:

4.0

Author:

Gary Russell, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

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

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
MqttPahoMessageHandler(java.lang.String clientId, MqttPahoClientFactory clientFactory) Use this constructor if the server URI(s) are provided by the MqttConnectOptions.getServerURIs() provided by the MqttPahoClientFactory.
MqttPahoMessageHandler(java.lang.String url, java.lang.String clientId) Use this URL when you don't need additional MqttConnectOptions.
MqttPahoMessageHandler(java.lang.String url, java.lang.String clientId, MqttPahoClientFactory clientFactory) 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).

Method Summary

Modifier and Type	Method and Description
void	connectionLost(java.lang.Throwable cause)
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
protected void	doStart()
protected void	doStop()
void	messageArrived(java.lang.String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)
protected void	onInit() Subclasses may implement this for initialization logic.
protected void	publish(java.lang.String topic, java.lang.Object mqttMessage, org.springframework.messaging.Message<?> message)
void	setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
void	setAsync(boolean async) Set to true if you don't want to block when sending messages.
void	setAsyncEvents(boolean asyncEvents) When setAsync(boolean) is true, setting this to true enables publication of MqttMessageSentEvent and MqttMessageDeliveredEvent to be emitted.
void	setCompletionTimeout(int completionTimeout) Set the completion timeout for async operations.

Methods inherited from class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler

getClientId, getClientInstance, getComponentType, getConverter, getUrl, handleMessageInternal, incrementClientInstance, isRunning, setConverter, setDefaultQos, setDefaultRetained, setDefaultTopic, setQosExpression, setQosExpressionString, setRetainedExpression, setRetainedExpressionString, setTopicExpression, setTopicExpressionString, start, stop

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

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

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, 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

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Constructor Detail

MqttPahoMessageHandler

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

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.

MqttPahoMessageHandler

public MqttPahoMessageHandler(java.lang.String clientId,
                              MqttPahoClientFactory clientFactory)

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.

Since:

4.1

MqttPahoMessageHandler

public MqttPahoMessageHandler(java.lang.String url,
                              java.lang.String clientId)

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

Parameters:

url - The URL.

clientId - The client id.

Method Detail

setAsync

public void setAsync(boolean async)

Set to true if you don't want to block when sending messages. Default false. When true, message sent/delivered events will be published for reception by a suitably configured 'ApplicationListener' or an event inbound-channel-adapter.

Parameters:

async - true for async.

Since:

4.1

setAsyncEvents

public void setAsyncEvents(boolean asyncEvents)

When setAsync(boolean) is true, setting this to true enables publication of MqttMessageSentEvent and MqttMessageDeliveredEvent to be emitted. Default false.

Parameters:

asyncEvents - the asyncEvents.

Since:

4.1

setCompletionTimeout

public void setCompletionTimeout(int completionTimeout)

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

Parameters:

completionTimeout - The timeout.

Since:

4.1

setApplicationEventPublisher

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

Specified by:

setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAware

onInit

protected void onInit()
               throws java.lang.Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class AbstractMqttMessageHandler

Throws:

java.lang.Exception - Any exception.

doStart

protected void doStart()

Specified by:

doStart in class AbstractMqttMessageHandler

doStop

protected void doStop()

Specified by:

doStop in class AbstractMqttMessageHandler

publish

protected void publish(java.lang.String topic,
                       java.lang.Object mqttMessage,
                       org.springframework.messaging.Message<?> message)
                throws java.lang.Exception

Specified by:

publish in class AbstractMqttMessageHandler

Throws:

java.lang.Exception

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 message)
                    throws java.lang.Exception

Specified by:

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

Throws:

java.lang.Exception

deliveryComplete

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

Specified by:

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