public interface MqttMessageConverter
extends org.springframework.messaging.converter.MessageConverter
MessageConverter allowing the topic to be added as
a header.| Modifier and Type | Method and Description |
|---|---|
static MessageProcessor<java.lang.Integer> |
defaultQosProcessor() |
static MessageProcessor<java.lang.Boolean> |
defaultRetainedProcessor() |
org.springframework.messaging.Message<?> |
toMessage(java.lang.String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
Convert to a Message.
|
org.springframework.messaging.Message<?> toMessage(java.lang.String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
topic - The topic.mqttMessage - The MQTT message.static MessageProcessor<java.lang.Integer> defaultQosProcessor()
static MessageProcessor<java.lang.Boolean> defaultRetainedProcessor()