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.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
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport |
logger |
Fields inherited from interface org.springframework.core.Ordered |
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE |
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 |
MqttPahoMessageHandler
public MqttPahoMessageHandler(java.lang.String url,
java.lang.String clientId,
MqttPahoClientFactory factory)
MqttPahoMessageHandler
public MqttPahoMessageHandler(java.lang.String url,
java.lang.String clientId)
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