The definition for the Spring Integration MqttAdapter
Inbound Channel Adapter.
Specifies one or more (comma-delimited) topics on which to listen for messages.
Specifies the QoS to use when subscribing to topics; default '1'. This can be single
value (applying to all topics); otherwise it must be a comma-delimited list corresponding
to the provided topics (the name number of elements must be provided).
If a downstream exception is thrown and an error-channel is specified,
the MessagingException will be sent to this channel. Otherwise, any such exception
will be logged.
Defines an outbound Channel Adapter.
Channel from which messages will be output.
When a message is sent to this channel it will
cause the query
to be executed.
Specifies the order for invocation when this endpoint is connected as a
subscriber to a SubscribableChannel.
Specifies the default topic to which messages will be sent. Required if an
outbound message does not have an 'mqtt_topic' header.
Specifies the default quality of service. Default 0.
Specifies the default value of the 'retained' flag. Default false.
Specifies that sends should not block, with the thread returning
immediately the message is sent. When 'true', message
sent and message delivery events can be published; see 'async-events'.
Default: 'false'.
When 'async' is true, specifies that message
sent and message delivery events will be published for reception
by a suitably configured 'ApplicationListener' or an event
inbound-channel-adapter.
Default: 'false'.
Identifies the underlying Spring bean definition, which is an
instance of either 'EventDrivenConsumer' or 'PollingConsumer',
depending on whether the component's input channel is a
'SubscribableChannel' or 'PollableChannel'.
Flag to indicate that the component should start automatically
on startup (default true).
Flag to indicate the phase in which the component should start automatically
on startup. See SmartLifecycle.
MQTT broker URL.
MQTT client ID.
to/from
a paho MqttMessage. Default is DefaultMqttMessageConverter.
]]>