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