Defines a Message Producing Endpoint for the
'org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter' that
subscribes to the MQTT topic(s) and produces messages to the channel.
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.
Configures a Consumer Endpoint for the
'org.springframework.integration.mqtt.outbound.MqttPahoMessageDrivenChannelAdapter'
that sends messages to the MQTT topic.
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
the 'topic-expression' evaluates to 'null'
Specifies an expression to evaluate to determine the destination topic.
Default "headers['mqtt_topic']".
Specifies the default quality of service; used if the 'qos-expression'
evaluates to 'null'. Default 0.
Specifies an expression to evaluate to determine the message qos.
Default "headers['mqtt_qos']".
Specifies the default value of the 'retained' flag; used if the
'retained-expression' evaluates to 'null'. Default false.
Specifies an expression to evaluate to determine the message 'retained'
flag. Default "headers['mqtt_retained']".
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.
]]>