public interface MqttMessageConverter extends MessageConverter
MessageConverter
の拡張。修飾子と型 | メソッドと説明 |
---|---|
static MessageProcessor<IntegerSE> | defaultQosProcessor() |
static MessageProcessor<BooleanSE> | defaultRetainedProcessor() |
Message<?> | toMessage(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) メッセージに変換します。 |
AbstractIntegrationMessageBuilder<?> | toMessageBuilder(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) メッセージビルダーに変換します。 |
fromMessage, toMessage
Message<?> toMessage(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
topic
- トピック。mqttMessage
- MQTT メッセージ。AbstractIntegrationMessageBuilder<?> toMessageBuilder(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
topic
- トピック。mqttMessage
- MQTT メッセージ。static MessageProcessor<IntegerSE> defaultQosProcessor()
static MessageProcessor<BooleanSE> defaultRetainedProcessor()