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, Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, Ordered, Orderable, TrackableComponent, NamedComponent, MessageHandler

public class MqttPahoMessageHandler
extends AbstractMqttMessageHandler
implements org.eclipse.paho.client.mqttv3.MqttCallback

Eclipse Paho implementation.

Since:

4.0

Author:

Gary Russell

Field Summary

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

logger

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
MqttPahoMessageHandler(java.lang.String url, java.lang.String clientId)
MqttPahoMessageHandler(java.lang.String url, java.lang.String clientId, MqttPahoClientFactory factory)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	connectIfNeeded()
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	publish(java.lang.String topic, java.lang.Object mqttMessage)

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

getClientId, getComponentType, getPhase, getUrl, handleMessageInternal, isAutoStartup, isRunning, onInit, setAutoStartup, setConverter, setDefaultQos, setDefaultRetained, setDefaultTopic, setPhase, start, stop, stop

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

getOrder, handleMessage, setOrder, setShouldTrack

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

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, 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

Constructor Detail

MqttPahoMessageHandler

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

MqttPahoMessageHandler

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

Method Detail

doStart

protected void doStart()

Specified by:

doStart in class AbstractMqttMessageHandler

doStop

protected void doStop()

Specified by:

doStop in class AbstractMqttMessageHandler

connectIfNeeded

protected void connectIfNeeded()

Specified by:

connectIfNeeded in class AbstractMqttMessageHandler

publish

protected void publish(java.lang.String topic,
           java.lang.Object mqttMessage)
                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