- messageArrived(String, MqttMessage) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
- messageArrived(String, MqttMessage) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
- messageToMqttBytes(Message<?>) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Subclasses can override this method to convert the payload to a byte[].
- mqttBytesToPayload(MqttMessage) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Subclasses can override this method to convert the byte[] to a payload.
- MqttConnectionFailedEvent - Class in org.springframework.integration.mqtt.event
-
- MqttConnectionFailedEvent(Object, Throwable) - Constructor for class org.springframework.integration.mqtt.event.MqttConnectionFailedEvent
-
- MqttHeaders - Class in org.springframework.integration.mqtt.support
-
Spring Integration headers.
- MqttIntegrationEvent - Class in org.springframework.integration.mqtt.event
-
Base class for Mqtt Events.
- MqttIntegrationEvent(Object) - Constructor for class org.springframework.integration.mqtt.event.MqttIntegrationEvent
-
- MqttIntegrationEvent(Object, Throwable) - Constructor for class org.springframework.integration.mqtt.event.MqttIntegrationEvent
-
- MqttMessageConverter - Interface in org.springframework.integration.mqtt.support
-
Extension of MessageConverter allowing the topic to be added as
a header.
- MqttMessageDeliveredEvent - Class in org.springframework.integration.mqtt.event
-
An event emitted (when using aysnc) when the client indicates the message
was delivered.
- MqttMessageDeliveredEvent(Object, int, String, int) - Constructor for class org.springframework.integration.mqtt.event.MqttMessageDeliveredEvent
-
- MqttMessageDeliveryEvent - Class in org.springframework.integration.mqtt.event
-
Base class for events related to message delivery.
- MqttMessageDeliveryEvent(Object, int, String, int) - Constructor for class org.springframework.integration.mqtt.event.MqttMessageDeliveryEvent
-
- MqttMessageDrivenChannelAdapterParser - Class in org.springframework.integration.mqtt.config.xml
-
The MqttAdapter Message Driven Channel adapter parser
- MqttMessageDrivenChannelAdapterParser() - Constructor for class org.springframework.integration.mqtt.config.xml.MqttMessageDrivenChannelAdapterParser
-
- MqttMessageSentEvent - Class in org.springframework.integration.mqtt.event
-
An event emitted (when using aysnc) when the client indicates that a message
has been sent.
- MqttMessageSentEvent(Object, Message<?>, String, int, String, int) - Constructor for class org.springframework.integration.mqtt.event.MqttMessageSentEvent
-
- MqttNamespaceHandler - Class in org.springframework.integration.mqtt.config.xml
-
The namespace handler for the MqttAdapter namespace
- MqttNamespaceHandler() - Constructor for class org.springframework.integration.mqtt.config.xml.MqttNamespaceHandler
-
- MqttOutboundChannelAdapterParser - Class in org.springframework.integration.mqtt.config.xml
-
The parser for the MqttAdapter Outbound Channel Adapter.
- MqttOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.mqtt.config.xml.MqttOutboundChannelAdapterParser
-
- MqttPahoClientFactory - Interface in org.springframework.integration.mqtt.core
-
- MqttPahoMessageDrivenChannelAdapter - Class in org.springframework.integration.mqtt.inbound
-
Eclipse Paho Implementation.
- MqttPahoMessageDrivenChannelAdapter(String, String, MqttPahoClientFactory, String...) - Constructor for class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
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, MqttPahoClientFactory, String...) - Constructor for class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
Use this constructor if the server URI(s) are provided by the
MqttConnectOptions.getServerURIs()
provided by the
MqttPahoClientFactory.
- MqttPahoMessageDrivenChannelAdapter(String, String, String...) - Constructor for class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
Use this URL when you don't need additional MqttConnectOptions.
- MqttPahoMessageHandler - Class in org.springframework.integration.mqtt.outbound
-
Eclipse Paho implementation.
- MqttPahoMessageHandler(String, String, MqttPahoClientFactory) - Constructor for class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
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).
- MqttPahoMessageHandler(String, MqttPahoClientFactory) - Constructor for class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
Use this constructor if the server URI(s) are provided by the
MqttConnectOptions.getServerURIs()
provided by the
MqttPahoClientFactory.
- MqttPahoMessageHandler(String, String) - Constructor for class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
Use this URL when you don't need additional MqttConnectOptions.
- MqttParserUtils - Class in org.springframework.integration.mqtt.config.xml
-
Contains various utility methods for parsing Mqtt Adapter
specific namespace elements as well as for the generation of the the
respective BeanDefinitions.
- MqttSubscribedEvent - Class in org.springframework.integration.mqtt.event
-
- MqttSubscribedEvent(Object, String) - Constructor for class org.springframework.integration.mqtt.event.MqttSubscribedEvent
-
- MqttUtils - Class in org.springframework.integration.mqtt.support
-
Contains utility methods used by the MqttAdapter components.
- setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
- setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
- setAsync(boolean) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
Set to true if you don't want to block when sending messages.
- setAsyncEvents(boolean) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
- setBeanFactory(BeanFactory) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
- setBytesMessageMapper(BytesMessageMapper) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Set a BytesMessageMapper to use when mapping byte[].
- setCleanSession(Boolean) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
- setCompletionTimeout(int) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
Set the completion timeout for operations.
- setCompletionTimeout(int) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
Set the completion timeout for async operations.
- setConnectionOptions(MqttConnectOptions) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
Set the preconfigured MqttConnectOptions.
- setConnectionTimeout(Integer) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
- setConsumerStopAction(ConsumerStopAction) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
Set the consumer stop action.
- setConverter(MqttMessageConverter) - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
-
- setConverter(MessageConverter) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the message converter to use; if this is provided, the adapter qos and retained
settings are ignored.
- setDefaultQos(int) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
- setDefaultRetained(boolean) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
- setDefaultTopic(String) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the topic to which the message will be published if the
topicExpression evaluates to `null`.
- setKeepAliveInterval(Integer) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
- setPassword(String) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
- setPayloadAsBytes(boolean) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
True if the converter should not convert the message payload to a String.
- setPersistence(MqttClientPersistence) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
Set the persistence to pass into the client constructor.
- setQos(int...) - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
-
Set the QoS for each topic; a single value will apply to all topics otherwise
the correct number of qos values must be provided.
- setQosExpression(Expression) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the qos expression; default "headers['mqtt_qos']".
- setQosExpressionString(String) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the qos expression; default "headers['mqtt_qos']".
- setRecoveryInterval(int) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
The time (ms) to wait between reconnection attempts.
- setRetainedExpression(Expression) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the retained expression; default "headers['mqtt_retained']".
- setRetainedExpressionString(String) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the retained expression; default "headers['mqtt_retained']".
- setServerURIs(String...) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
- setSocketFactory(SocketFactory) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
- setSslProperties(Properties) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
- setTopicExpression(Expression) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the topic expression; default "headers['mqtt_topic']".
- setTopicExpressionString(String) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the topic expression; default "headers['mqtt_topic']".
- setUserName(String) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
- setWill(DefaultMqttPahoClientFactory.Will) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
- shouldGenerateId() - Method in class org.springframework.integration.mqtt.config.xml.MqttOutboundChannelAdapterParser
-
- shouldGenerateIdAsFallback() - Method in class org.springframework.integration.mqtt.config.xml.MqttOutboundChannelAdapterParser
-
- start() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
- stop() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-