Index
A C D F G H I M O P Q R S T U V W
All Classes|All Packages
All Classes|All Packages
All Classes|All Packages
A
- AbstractMqttMessageDrivenChannelAdapter - Class in org.springframework.integration.mqtt.inbound
-
Abstract class for MQTT Message-Driven Channel Adapters.
- AbstractMqttMessageDrivenChannelAdapter(String, String, String...) - Constructor for class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
- AbstractMqttMessageHandler - Class in org.springframework.integration.mqtt.outbound
-
Abstract class for MQTT outbound channel adapters.
- AbstractMqttMessageHandler(String, String) - Constructor for class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- addTopic(String...) - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
-
Add a topic (or topics) to the subscribed list (qos=1).
- addTopic(String, int) - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
-
Add a topic to the subscribed list.
- addTopic(String, int) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
- addTopics(String[], int[]) - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
-
Add topics to the subscribed list.
C
- cloneConnectOptions(MqttConnectOptions) - Static method in class org.springframework.integration.mqtt.support.MqttUtils
-
Clone the
MqttConnectOptions, except the serverUris. - connectionLost(Throwable) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
- connectionLost(Throwable) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
- ConsumerStopAction - Enum in org.springframework.integration.mqtt.core
-
Action to take regarding subscrptions when consumer stops.
D
- DEFAULT_COMPLETION_TIMEOUT - Static variable in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
The default completion timeout in milliseconds.
- DEFAULT_COMPLETION_TIMEOUT - Static variable in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
The default completion timeout in milliseconds.
- DefaultMqttPahoClientFactory - Class in org.springframework.integration.mqtt.core
-
Creates a default
MqttClientand a set of options as configured. - DefaultMqttPahoClientFactory() - Constructor for class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
- DefaultMqttPahoClientFactory.Will - Class in org.springframework.integration.mqtt.core
- DefaultPahoMessageConverter - Class in org.springframework.integration.mqtt.support
-
Default implementation for mapping to/from Messages.
- DefaultPahoMessageConverter() - Constructor for class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Construct a converter with default options (qos=0, retain=false, charset=UTF-8).
- DefaultPahoMessageConverter(int, boolean) - Constructor for class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Construct a converter to create outbound messages with the supplied default qos and retain settings and a UTF-8 charset for converting outbound String payloads to
byte[]and inboundbyte[]to String (unlesspayloadAdBytesis true). - DefaultPahoMessageConverter(int, boolean, String) - Constructor for class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Construct a converter to create outbound messages with the supplied default qos and retain settings and the supplied charset.
- DefaultPahoMessageConverter(int, MessageProcessor<Integer>, boolean, MessageProcessor<Boolean>) - Constructor for class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Construct a converter to create outbound messages with the supplied default qos and retained message processors and a UTF-8 charset for converting outbound String payloads to
byte[]and inboundbyte[]to String (unlesspayloadAdBytesis true). - DefaultPahoMessageConverter(int, MessageProcessor<Integer>, boolean, MessageProcessor<Boolean>, String) - Constructor for class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Construct a converter to create outbound messages with the supplied default qos and retain settings and the supplied charset.
- DefaultPahoMessageConverter(String) - Constructor for class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Construct a converter with default options (qos=0, retain=false) and the supplied charset.
- defaultQosProcessor() - Static method in interface org.springframework.integration.mqtt.support.MqttMessageConverter
- defaultRetainedProcessor() - Static method in interface org.springframework.integration.mqtt.support.MqttMessageConverter
- deliveryComplete(IMqttDeliveryToken) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
- deliveryComplete(IMqttDeliveryToken) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
- DISCONNECT_COMPLETION_TIMEOUT - Static variable in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
The default disconnect completion timeout in milliseconds.
- DISCONNECT_COMPLETION_TIMEOUT - Static variable in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
The default disconnect completion timeout in milliseconds.
- doParse(Element, ParserContext, String) - Method in class org.springframework.integration.mqtt.config.xml.MqttMessageDrivenChannelAdapterParser
- doStart() - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
- doStart() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- doStart() - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
- doStop() - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
- doStop() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- doStop() - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
- duplicate(Message<?>) - Static method in class org.springframework.integration.mqtt.support.MqttHeaderAccessor
-
Return the duplicate header.
- DUPLICATE - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
F
- fromMessage(Message<?>, Class<?>) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
G
- getAsyncClientInstance(String, String) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
- getAsyncClientInstance(String, String) - Method in interface org.springframework.integration.mqtt.core.MqttPahoClientFactory
-
Retrieve an async client instance.
- getBeanFactory() - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
- getBeanName() - Method in interface org.springframework.integration.mqtt.core.MqttComponent
-
Return this component's bean name.
- getClientId() - Method in class org.springframework.integration.mqtt.event.MqttMessageDeliveryEvent
- getClientId() - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
- getClientId() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- getClientInstance() - Method in class org.springframework.integration.mqtt.event.MqttMessageDeliveryEvent
- getClientInstance() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Incremented each time the client is connected.
- getClientInstance(String, String) - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
- getClientInstance(String, String) - Method in interface org.springframework.integration.mqtt.core.MqttPahoClientFactory
-
Retrieve a client instance.
- getComponentType() - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
- getComponentType() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- getConnectionInfo() - Method in interface org.springframework.integration.mqtt.core.MqttComponent
-
Return information about the connection.
- getConnectionInfo() - Method in interface org.springframework.integration.mqtt.core.MqttPahoComponent
- getConnectionInfo() - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
- getConnectionInfo() - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
- getConnectionOptions() - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
- getConnectionOptions() - Method in interface org.springframework.integration.mqtt.core.MqttPahoClientFactory
-
Retrieve the connection options.
- getConsumerStopAction() - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
-
Get the consumer stop action.
- getConsumerStopAction() - Method in interface org.springframework.integration.mqtt.core.MqttPahoClientFactory
-
Get the consumer stop action.
- getConverter() - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
- getConverter() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- getMessage() - Method in class org.springframework.integration.mqtt.event.MqttMessageSentEvent
- getMessage() - Method in class org.springframework.integration.mqtt.event.MqttSubscribedEvent
- getMessageBuilderFactory() - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
- getMessageId() - Method in class org.springframework.integration.mqtt.event.MqttMessageDeliveryEvent
- getPayload() - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory.Will
- getQos() - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory.Will
- getQos() - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
- getTopic() - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory.Will
- getTopic() - Method in class org.springframework.integration.mqtt.event.MqttMessageSentEvent
- getTopic() - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
- getUrl() - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
- getUrl() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
H
- handleMessageInternal(Message<?>) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
I
- id(Message<?>) - Static method in class org.springframework.integration.mqtt.support.MqttHeaderAccessor
-
Return the MQTT message id.
- ID - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
- incrementClientInstance() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- init() - Method in class org.springframework.integration.mqtt.config.xml.MqttNamespaceHandler
- isPayloadAsBytes() - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
- isRetained() - Method in class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory.Will
- isRunning() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
M
- 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.
- MqttComponent<T> - Interface in org.springframework.integration.mqtt.core
-
A component that interfaces with MQTT.
- MqttConnectionFailedEvent - Class in org.springframework.integration.mqtt.event
- MqttConnectionFailedEvent(Object, Throwable) - Constructor for class org.springframework.integration.mqtt.event.MqttConnectionFailedEvent
- MqttHeaderAccessor - Class in org.springframework.integration.mqtt.support
-
Helper for typed access to incoming MQTT message headers.
- 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
MessageConverterallowing 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
- MqttPahoComponent - Interface in org.springframework.integration.mqtt.core
-
An extension of
MqttComponentfor Eclipse Paho components. - MqttPahoMessageDrivenChannelAdapter - Class in org.springframework.integration.mqtt.inbound
-
Eclipse Paho Implementation.
- MqttPahoMessageDrivenChannelAdapter(String, String, String...) - Constructor for class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
Use this constructor when you don't need additional
MqttConnectOptions. - 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 theMqttPahoClientFactory). - 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 theMqttPahoClientFactory. - MqttPahoMessageHandler - Class in org.springframework.integration.mqtt.outbound
-
Eclipse Paho Implementation.
- MqttPahoMessageHandler(String, String) - Constructor for class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
Use this constructor when you don't need additional
MqttConnectOptions. - 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 theMqttPahoClientFactory). - 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 theMqttPahoClientFactory. - 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
-
MQTT Utilities
O
- onInit() - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
- onInit() - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- onInit() - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
- org.springframework.integration.mqtt.config.xml - package org.springframework.integration.mqtt.config.xml
-
Provides parser classes to provide Xml namespace support for the MqttAdapter components.
- org.springframework.integration.mqtt.core - package org.springframework.integration.mqtt.core
-
Provides core classes of the MqttAdapter module.
- org.springframework.integration.mqtt.event - package org.springframework.integration.mqtt.event
-
ApplicationEvents generated by the mqtt module.
- org.springframework.integration.mqtt.inbound - package org.springframework.integration.mqtt.inbound
-
Provides inbound Spring Integration MqttAdapter components.
- org.springframework.integration.mqtt.outbound - package org.springframework.integration.mqtt.outbound
-
Provides Spring Integration components for doing outbound operations.
- org.springframework.integration.mqtt.support - package org.springframework.integration.mqtt.support
-
Provides various support classes used across Spring Integration MqttAdapter Components.
P
- parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.mqtt.config.xml.MqttOutboundChannelAdapterParser
- PREFIX - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
- publish(String, Object, Message<?>) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
- publish(String, Object, Message<?>) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
Q
- QOS - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
R
- RECEIVED_QOS - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
- RECEIVED_RETAINED - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
- RECEIVED_TOPIC - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
- receivedQos(Message<?>) - Static method in class org.springframework.integration.mqtt.support.MqttHeaderAccessor
-
Return the received QOS header.
- receivedRetained(Message<?>) - Static method in class org.springframework.integration.mqtt.support.MqttHeaderAccessor
-
Return the received retained header.
- receivedTopic(Message<?>) - Static method in class org.springframework.integration.mqtt.support.MqttHeaderAccessor
-
Return the received topic header.
- removeTopic(String...) - Method in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
-
Remove a topic (or topics) from the subscribed list.
- removeTopic(String...) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
- RETAINED - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
S
- 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
-
When
MqttPahoMessageHandler.setAsync(boolean)is true, setting this to true enables publication ofMqttMessageSentEventandMqttMessageDeliveredEventto be emitted. - setBeanFactory(BeanFactory) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
- setBytesMessageMapper(BytesMessageMapper) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
-
Set a
BytesMessageMapperto use when mapping byte[]. - setCompletionTimeout(long) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
Set the completion timeout for operations.
- setCompletionTimeout(long) - 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. - 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
-
Set the qos for messages if the
qosExpressionevaluates to null. - setDefaultRetained(boolean) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the retained boolean for messages if the
retainedExpressionevaluates to null. - setDefaultTopic(String) - Method in class org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler
-
Set the topic to which the message will be published if the
topicExpressionevaluates to `null`. - setDisconnectCompletionTimeout(long) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
Set the completion timeout when disconnecting.
- setDisconnectCompletionTimeout(long) - Method in class org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
-
Set the completion timeout when disconnecting.
- setManualAcks(boolean) - Method in class org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
-
Set the acknowledgment mode to manual.
- 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']".
- 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']".
- 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
T
- toMessage(Object, MessageHeaders) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
- toMessage(String, MqttMessage) - Method in interface org.springframework.integration.mqtt.support.MqttMessageConverter
-
Convert to a Message.
- toMessageBuilder(String, MqttMessage) - Method in class org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
- toMessageBuilder(String, MqttMessage) - Method in interface org.springframework.integration.mqtt.support.MqttMessageConverter
-
Convert to a message builder.
- TOPIC - Static variable in class org.springframework.integration.mqtt.support.MqttHeaders
- topicLock - Variable in class org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter
- toString() - Method in class org.springframework.integration.mqtt.event.MqttMessageDeliveredEvent
- toString() - Method in class org.springframework.integration.mqtt.event.MqttMessageSentEvent
- toString() - Method in class org.springframework.integration.mqtt.event.MqttSubscribedEvent
U
- UNSUBSCRIBE_ALWAYS - org.springframework.integration.mqtt.core.ConsumerStopAction
-
Always unsubscribe.
- UNSUBSCRIBE_CLEAN - org.springframework.integration.mqtt.core.ConsumerStopAction
-
Unsubscribe if clean session is true.
- UNSUBSCRIBE_NEVER - org.springframework.integration.mqtt.core.ConsumerStopAction
-
Never unsubscribe.
V
- valueOf(String) - Static method in enum org.springframework.integration.mqtt.core.ConsumerStopAction
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.springframework.integration.mqtt.core.ConsumerStopAction
-
Returns an array containing the constants of this enum type, in the order they are declared.
W
- Will(String, byte[], int, boolean) - Constructor for class org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory.Will
All Classes|All Packages