public class MqttPahoMessageHandler extends AbstractMqttMessageHandler implements org.eclipse.paho.client.mqttv3.MqttCallback
loggerHIGHEST_PRECEDENCE, LOWEST_PRECEDENCE| Constructor and Description |
|---|
MqttPahoMessageHandler(String url,
String clientId) |
MqttPahoMessageHandler(String url,
String clientId,
MqttPahoClientFactory factory) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
connectIfNeeded() |
void |
connectionLost(Throwable cause) |
void |
deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token) |
protected void |
doStart() |
protected void |
doStop() |
void |
messageArrived(String topic,
org.eclipse.paho.client.mqttv3.MqttMessage message) |
protected void |
publish(String topic,
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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic MqttPahoMessageHandler(String url, String clientId, MqttPahoClientFactory factory)
protected void doStart()
doStart in class AbstractMqttMessageHandlerprotected void doStop()
doStop in class AbstractMqttMessageHandlerprotected void connectIfNeeded()
connectIfNeeded in class AbstractMqttMessageHandlerprotected void publish(String topic, Object mqttMessage) throws Exception
publish in class AbstractMqttMessageHandlerExceptionpublic void connectionLost(Throwable cause)
connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallbackpublic void messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage message) throws Exception
messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallbackExceptionpublic void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback