org.springframework.integration.mqtt.inbound

Class AbstractMqttMessageDrivenChannelAdapter

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.MessageProducerSupport

org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, MessageProducer, NamedComponent, TrackableComponent

Direct Known Subclasses:

MqttPahoMessageDrivenChannelAdapter

@ManagedResource
 @IntegrationManagedResource
public abstract class AbstractMqttMessageDrivenChannelAdapter
extends MessageProducerSupport

Abstract class for MQTT Message-Driven Channel Adapters.

Since:

4.0

Author:

Gary Russell, Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
protected Lock	topicLock

Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint

lifecycleCondition, lifecycleLock

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor and Description
AbstractMqttMessageDrivenChannelAdapter(String url, String clientId, String... topic)

Method Summary

Modifier and Type	Method and Description
void	addTopic(String... topic) Add a topic (or topics) to the subscribed list (qos=1).
void	addTopic(String topic, int qos) Add a topic to the subscribed list.
void	addTopics(String[] topic, int[] qos) Add topics to the subscribed list.
protected String	getClientId()
String	getComponentType() Subclasses may implement this method to provide component type information.
protected MqttMessageConverter	getConverter()
int[]	getQos()
String[]	getTopic()
protected String	getUrl()
protected void	onInit() Subclasses may implement this for initialization logic.
void	removeTopic(String... topic) Remove a topic (or topics) from the subscribed list.
void	setConverter(MqttMessageConverter converter)
void	setQos(int... qos) Set the QoS for each topic; a single value will apply to all topics otherwise the correct number of qos values must be provided.

Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport

afterSingletonsInstantiated, buildErrorMessage, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, 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

getBeanName, getComponentName

Field Detail

topicLock

protected final Lock topicLock

Constructor Detail

AbstractMqttMessageDrivenChannelAdapter

public AbstractMqttMessageDrivenChannelAdapter(String url,
                                               String clientId,
                                               String... topic)

Method Detail

setConverter

public void setConverter(MqttMessageConverter converter)

setQos

public void setQos(int... qos)

Set the QoS for each topic; a single value will apply to all topics otherwise the correct number of qos values must be provided.

Parameters:

qos - The qos value(s).

Since:

4.1

getQos

@ManagedAttribute
public int[] getQos()

getUrl

protected String getUrl()

getClientId

protected String getClientId()

getConverter

protected MqttMessageConverter getConverter()

getTopic

@ManagedAttribute
public String[] getTopic()

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class IntegrationObjectSupport

addTopic

@ManagedOperation
public void addTopic(String topic,
                                       int qos)

Add a topic to the subscribed list.

Parameters:

topic - The topic.

qos - The qos.

Throws:

MessagingException - if the topic is already in the list.

Since:

4.1

addTopic

@ManagedOperation
public void addTopic(String... topic)

Add a topic (or topics) to the subscribed list (qos=1).

Parameters:

topic - The topics.

Throws:

MessagingException - if the topic is already in the list.

Since:

4.1

addTopics

@ManagedOperation
public void addTopics(String[] topic,
                                        int[] qos)

Add topics to the subscribed list.

Parameters:

topic - The topics.

qos - The qos for each topic.

Throws:

MessagingException - if a topic is already in the list.

Since:

4.1

removeTopic

@ManagedOperation
public void removeTopic(String... topic)

Remove a topic (or topics) from the subscribed list.

Parameters:

topic - The topic.

Throws:

MessagingException - if the topic is not in the list.

Since:

4.1

onInit

protected void onInit()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class MessageProducerSupport