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

public class MqttPahoMessageDrivenChannelAdapter
extends AbstractMqttMessageDrivenChannelAdapter
implements org.eclipse.paho.client.mqttv3.MqttCallback

Eclipse Paho Implementation.

Since:

1.0

Author:

Gary Russell

Field Summary

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

logger

Constructor Summary

Constructors

Constructor and Description
MqttPahoMessageDrivenChannelAdapter(String url, String clientId, MqttPahoClientFactory clientFactory, String... topic)
MqttPahoMessageDrivenChannelAdapter(String url, String clientId, String... topic)

Method Summary

Methods

Modifier and Type	Method and Description
void	connectionLost(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(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)

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

getClientId, getComponentType, getConverter, getTopic, getUrl, onInit, setConverter

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

sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack

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

getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop

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

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

MqttPahoMessageDrivenChannelAdapter

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

MqttPahoMessageDrivenChannelAdapter

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

Method Detail

doStart

protected void doStart()

Description copied from class: MessageProducerSupport

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

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

connectionLost

public void connectionLost(Throwable cause)

Specified by:

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

messageArrived

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

Specified by:

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

Throws:

Exception

deliveryComplete

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

Specified by:

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