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, toMessageMessage<?> 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()