public class MqttPahoMessageDrivenChannelAdapter extends AbstractMqttMessageDrivenChannelAdapter implements org.eclipse.paho.client.mqttv3.MqttCallback, ApplicationEventPublisherAware
topicLock
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
Constructor and Description |
---|
MqttPahoMessageDrivenChannelAdapter(String clientId,
MqttPahoClientFactory clientFactory,
String... topic)
Use this constructor if the server URI(s) are provided by the
MqttConnectOptions.getServerURIs()
provided by the MqttPahoClientFactory . |
MqttPahoMessageDrivenChannelAdapter(String url,
String clientId,
MqttPahoClientFactory clientFactory,
String... topic)
Use this constructor for a single url (although it may be overridden
if the server URI(s) are provided by the
MqttConnectOptions.getServerURIs()
provided by the MqttPahoClientFactory ). |
MqttPahoMessageDrivenChannelAdapter(String url,
String clientId,
String... topic)
Use this URL when you don't need additional
MqttConnectOptions . |
Modifier and Type | Method and Description |
---|---|
void |
addTopic(String topic,
int qos)
Add a topic to the subscribed list.
|
void |
connectionLost(Throwable cause) |
void |
deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token) |
protected void |
doStart()
Takes no action by default.
|
protected void |
doStop()
Takes no action by default.
|
void |
messageArrived(String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) |
void |
removeTopic(String... topic)
Remove a topic (or topics) from the subscribed list.
|
void |
setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void |
setCompletionTimeout(int completionTimeout)
Set the completion timeout for operations.
|
void |
setRecoveryInterval(int recoveryInterval)
The time (ms) to wait between reconnection attempts.
|
addTopic, addTopics, getClientId, getComponentType, getConverter, getQos, getTopic, getUrl, onInit, setConverter, setQos
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack
doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public MqttPahoMessageDrivenChannelAdapter(String url, String clientId, MqttPahoClientFactory clientFactory, String... topic)
MqttConnectOptions.getServerURIs()
provided by the MqttPahoClientFactory
).url
- the URL.clientId
- The client id.clientFactory
- The client factory.topic
- The topic(s).public MqttPahoMessageDrivenChannelAdapter(String clientId, MqttPahoClientFactory clientFactory, String... topic)
MqttConnectOptions.getServerURIs()
provided by the MqttPahoClientFactory
.clientId
- The client id.clientFactory
- The client factory.topic
- The topic(s).public void setCompletionTimeout(int completionTimeout)
completionTimeout
- The timeout.public void setRecoveryInterval(int recoveryInterval)
recoveryInterval
- the interval.public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher
in interface ApplicationEventPublisherAware
protected void doStart()
MessageProducerSupport
doStart
in class MessageProducerSupport
protected void doStop()
MessageProducerSupport
doStop
in class MessageProducerSupport
public void addTopic(String topic, int qos)
AbstractMqttMessageDrivenChannelAdapter
addTopic
in class AbstractMqttMessageDrivenChannelAdapter
topic
- The topic.qos
- The qos.public void removeTopic(String... topic)
AbstractMqttMessageDrivenChannelAdapter
removeTopic
in class AbstractMqttMessageDrivenChannelAdapter
topic
- The topic.public void connectionLost(Throwable cause)
connectionLost
in interface org.eclipse.paho.client.mqttv3.MqttCallback
public void messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) throws Exception
messageArrived
in interface org.eclipse.paho.client.mqttv3.MqttCallback
Exception
public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
deliveryComplete
in interface org.eclipse.paho.client.mqttv3.MqttCallback