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 Summary

Modifier and Type	Method	Description
static MessageProcessor<Integer>	defaultQosProcessor()
static MessageProcessor<Boolean>	defaultRetainedProcessor()
default Message<?>	toMessage(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)	Convert to a Message.
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 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()