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()