org.springframework.integration.mqtt.outbound
Class MqttPahoMessageHandler

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.handler.AbstractMessageHandler
          extended by org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
              extended by org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
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.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.core.Ordered, org.springframework.integration.context.Orderable, org.springframework.integration.history.TrackableComponent, org.springframework.integration.support.context.NamedComponent, org.springframework.messaging.MessageHandler

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

Eclipse Paho implementation.

Since:
1.0

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
MqttPahoMessageHandler(java.lang.String url, java.lang.String clientId)
           
MqttPahoMessageHandler(java.lang.String url, java.lang.String clientId, MqttPahoClientFactory factory)
           
 
Method Summary
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, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, 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