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 |
---|---|
org.springframework.messaging.Message<?> |
toMessage(String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
Convert to a Message.
|
org.springframework.messaging.Message<?> toMessage(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
topic
- The topic.mqttMessage
- The MQTT message.