public class MqttPahoMessageHandler extends AbstractMqttMessageHandler implements org.eclipse.paho.client.mqttv3.MqttCallback
| Constructor and Description |
|---|
MqttPahoMessageHandler(java.lang.String url,
java.lang.String clientId) |
MqttPahoMessageHandler(java.lang.String url,
java.lang.String clientId,
MqttPahoClientFactory factory) |
| 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) |
getClientId, getComponentType, getPhase, getUrl, handleMessageInternal, isAutoStartup, isRunning, onInit, setAutoStartup, setConverter, setDefaultQos, setDefaultRetained, setDefaultTopic, setPhase, start, stop, stopgetOrder, handleMessage, setOrder, setShouldTrackafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toStringpublic MqttPahoMessageHandler(java.lang.String url,
java.lang.String clientId,
MqttPahoClientFactory factory)
public MqttPahoMessageHandler(java.lang.String url,
java.lang.String clientId)
protected void doStart()
doStart in class AbstractMqttMessageHandlerprotected void doStop()
doStop in class AbstractMqttMessageHandlerprotected void connectIfNeeded()
connectIfNeeded in class AbstractMqttMessageHandlerprotected void publish(java.lang.String topic,
java.lang.Object mqttMessage)
throws java.lang.Exception
publish in class AbstractMqttMessageHandlerjava.lang.Exceptionpublic void connectionLost(java.lang.Throwable cause)
connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallbackpublic void messageArrived(java.lang.String topic,
org.eclipse.paho.client.mqttv3.MqttMessage message)
throws java.lang.Exception
messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallbackjava.lang.Exceptionpublic void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback