public interface MqttMessageConverter extends MessageConverter
MessageConverter
allowing the topic to be added as
a header.Modifier and Type | Method and Description |
---|---|
static MessageProcessor<Integer> |
defaultQosProcessor() |
static MessageProcessor<Boolean> |
defaultRetainedProcessor() |
Message<?> |
toMessage(String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
Convert to a Message.
|
default AbstractIntegrationMessageBuilder<?> |
toMessageBuilder(String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
Convert to a message builder.
|
fromMessage, toMessage
Message<?> toMessage(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
topic
- the topic.mqttMessage
- the MQTT message.default AbstractIntegrationMessageBuilder<?> toMessageBuilder(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
default
with a delegation to the toMessage(String, MqttMessage)
to avoid a breaking change for migrated projects.
The delegation will be swapped in the next version.topic
- the topic.mqttMessage
- the MQTT message.static MessageProcessor<Integer> defaultQosProcessor()
static MessageProcessor<Boolean> defaultRetainedProcessor()