public class MqttPahoMessageDrivenChannelAdapter extends AbstractMqttMessageDrivenChannelAdapter implements org.eclipse.paho.client.mqttv3.MqttCallback
| Constructor and Description |
|---|
MqttPahoMessageDrivenChannelAdapter(java.lang.String url,
java.lang.String clientId,
MqttPahoClientFactory clientFactory,
java.lang.String... topic) |
MqttPahoMessageDrivenChannelAdapter(java.lang.String url,
java.lang.String clientId,
java.lang.String... topic) |
| Modifier and Type | Method and Description |
|---|---|
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 mqttMessage) |
getClientId, getComponentType, getConverter, getTopic, getUrl, onInit, setConvertersendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrackgetPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, toStringpublic MqttPahoMessageDrivenChannelAdapter(java.lang.String url,
java.lang.String clientId,
MqttPahoClientFactory clientFactory,
java.lang.String... topic)
public MqttPahoMessageDrivenChannelAdapter(java.lang.String url,
java.lang.String clientId,
java.lang.String... topic)
protected void doStart()
doStart in class org.springframework.integration.endpoint.MessageProducerSupportprotected void doStop()
doStop in class org.springframework.integration.endpoint.MessageProducerSupportpublic 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 mqttMessage)
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