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

Method Summary

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.
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 Detail

toMessage

Message<?> toMessage(String topic,
                     org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)

Convert to a Message.

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