Interface MqttMessageConverter
- All Superinterfaces:
org.springframework.messaging.converter.MessageConverter
- All Known Implementing Classes:
DefaultPahoMessageConverter
public interface MqttMessageConverter
extends org.springframework.messaging.converter.MessageConverter
Extension of
MessageConverter allowing the topic to be added as
a header.- Since:
- 4.0
-
Method Summary
Modifier and TypeMethodDescriptionstatic org.springframework.integration.handler.MessageProcessor<Integer>static org.springframework.integration.handler.MessageProcessor<Boolean>default org.springframework.messaging.Message<?>Convert to a Message.org.springframework.integration.support.AbstractIntegrationMessageBuilder<?>toMessageBuilder(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) Convert to a message builder.Methods inherited from interface org.springframework.messaging.converter.MessageConverter
fromMessage, toMessage
-
Method Details
-
toMessage
default org.springframework.messaging.Message<?> toMessage(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) Convert to a Message. The default implementation callstoMessageBuilder(String, MqttMessage).- Parameters:
topic- the topic.mqttMessage- the MQTT message.- Returns:
- the Message.
-
toMessageBuilder
org.springframework.integration.support.AbstractIntegrationMessageBuilder<?> toMessageBuilder(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) Convert to a message builder.- Parameters:
topic- the topic.mqttMessage- the MQTT message.- Returns:
- the builder.
-
defaultQosProcessor
-
defaultRetainedProcessor
-