Package org.springframework.integration.mqtt.support

Interface MqttMessageConverter

All Superinterfaces:
MessageConverter
All Known Implementing Classes:
DefaultPahoMessageConverter
public interface MqttMessageConverter extends MessageConverter
Extension of MessageConverter allowing the topic to be added as a header.
Since:
4.0
Author:
Gary Russell, Artem Bilan

  • Method Details

    • toMessage

      default Message<?> toMessage(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
      Convert to a Message. The default implementation calls toMessageBuilder(String, MqttMessage).
      Parameters:
      topic - the topic.
      mqttMessage - the MQTT message.
      Returns:
      the Message.

    • toMessageBuilder

      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

      static MessageProcessor<Integer> defaultQosProcessor()

    • defaultRetainedProcessor

      static MessageProcessor<Boolean> defaultRetainedProcessor()