クラス DefaultPahoMessageConverter
java.lang.ObjectSE
org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
- 実装されたすべてのインターフェース:
Aware
、BeanFactoryAware
、MqttMessageConverter
、MessageConverter
public class DefaultPahoMessageConverter
extends ObjectSE
implements MqttMessageConverter, BeanFactoryAware
メッセージとの間でマッピングするためのデフォルトの実装。
- 導入:
- 4.0
- 作成者:
- Gary Russell, Artem Bilan
コンストラクターのサマリー
コンストラクターコンストラクター説明デフォルトのオプション(qos = 0、retain = false、charset = UTF-8)を使用してコンバーターを構築します。DefaultPahoMessageConverter
(int defaultQos, boolean defaultRetained) コンバーターを構築して、提供されたデフォルトの QoS を使用して送信メッセージを作成し、設定と、送信文字列ペイロードをbyte[]
に、受信byte[]
を文字列に変換するための UTF-8 文字セットを保持します(payloadAdBytes
が true でない場合)。DefaultPahoMessageConverter
(int defaultQos, boolean defaultRetained, StringSE charset) コンバーターを構築して、提供されたデフォルトの QoS を使用して送信メッセージを作成し、設定と提供された文字セットを保持します。DefaultPahoMessageConverter
(int defaultQos, MessageProcessor<IntegerSE> qosProcessor, boolean defaultRetained, MessageProcessor<BooleanSE> retainedProcessor) 提供されたデフォルトの QoS と保持されたメッセージプロセッサー、および送信文字列ペイロードをbyte[]
に、受信byte[]
を文字列に変換するための UTF-8 文字セットを使用して送信メッセージを作成するコンバーターを構築します(payloadAdBytes
が true でない場合)。DefaultPahoMessageConverter
(int defaultQos, MessageProcessor<IntegerSE> qosProcessor, boolean defaultRetained, MessageProcessor<BooleanSE> retainedProcessor, StringSE charset) コンバーターを構築して、提供されたデフォルトの QoS を使用して送信メッセージを作成し、設定と提供された文字セットを保持します。DefaultPahoMessageConverter
(StringSE charset) デフォルトのオプション(qos = 0、retain = false)と提供された文字セットを使用してコンバーターを構築します。メソッドのサマリー
修飾子と型メソッド説明org.eclipse.paho.client.mqttv3.MqttMessage
fromMessage
(Message<?> message, ClassSE<?> targetClass) protected BeanFactory
protected MessageBuilderFactory
boolean
protected byte[]
messageToMqttBytes
(Message<?> message) サブクラスはこのメソッドをオーバーライドして、ペイロードを byte[] に変換できます。protected ObjectSE
mqttBytesToPayload
(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) サブクラスはこのメソッドをオーバーライドして、byte[] をペイロードに変換できます。final void
setBeanFactory
(BeanFactory beanFactory) void
setBytesMessageMapper
(BytesMessageMapper bytesMessageMapper) byte[] をマッピングするときに使用するBytesMessageMapper
を設定します。void
setPayloadAsBytes
(boolean payloadAsBytes) コンバーターがメッセージペイロードを文字列に変換してはならない場合は True。Message<?>
toMessage
(ObjectSE mqttMessage, MessageHeaders headers) toMessageBuilder
(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) メッセージビルダーに変換します。クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
インターフェース org.springframework.integration.mqtt.support.MqttMessageConverter から継承されたメソッド
toMessage
コンストラクターの詳細
DefaultPahoMessageConverter
public DefaultPahoMessageConverter()デフォルトのオプション(qos = 0、retain = false、charset = UTF-8)を使用してコンバーターを構築します。DefaultPahoMessageConverter
public DefaultPahoMessageConverter(int defaultQos, boolean defaultRetained) コンバーターを構築して、提供されたデフォルトの QoS を使用して送信メッセージを作成し、設定と、送信文字列ペイロードをbyte[]
に、受信byte[]
を文字列に変換するための UTF-8 文字セットを保持します(payloadAdBytes
が true でない場合)。- パラメーター:
defaultQos
- デフォルトの QoS。defaultRetained
- デフォルトは保持されます。
DefaultPahoMessageConverter
デフォルトのオプション(qos = 0、retain = false)と提供された文字セットを使用してコンバーターを構築します。- パラメーター:
charset
- 送信文字列ペイロードをbyte[]
に変換し、受信byte[]
を文字列に変換するために使用される文字セット(payloadAdBytes
が true の場合を除く)。- 導入:
- 4.1.2
DefaultPahoMessageConverter
コンバーターを構築して、提供されたデフォルトの QoS を使用して送信メッセージを作成し、設定と提供された文字セットを保持します。- パラメーター:
defaultQos
- デフォルトの QoS。defaultRetained
- デフォルトは保持されます。charset
- 送信文字列ペイロードをbyte[]
に変換し、受信byte[]
を文字列に変換するために使用される文字セット(payloadAdBytes
が true の場合を除く)。
DefaultPahoMessageConverter
public DefaultPahoMessageConverter(int defaultQos, MessageProcessor<IntegerSE> qosProcessor, boolean defaultRetained, MessageProcessor<BooleanSE> retainedProcessor) 提供されたデフォルトの QoS と保持されたメッセージプロセッサー、および送信文字列ペイロードをbyte[]
に、受信byte[]
を文字列に変換するための UTF-8 文字セットを使用して送信メッセージを作成するコンバーターを構築します(payloadAdBytes
が true でない場合)。- パラメーター:
defaultQos
- デフォルトの QoS。qosProcessor
- QOS を決定するためのメッセージプロセッサー。defaultRetained
- デフォルトは保持されます。retainedProcessor
- 保持されたフラグを判別するためのメッセージプロセッサー。- 導入:
- 5.0
DefaultPahoMessageConverter
public DefaultPahoMessageConverter(int defaultQos, MessageProcessor<IntegerSE> qosProcessor, boolean defaultRetained, MessageProcessor<BooleanSE> retainedProcessor, StringSE charset) コンバーターを構築して、提供されたデフォルトの QoS を使用して送信メッセージを作成し、設定と提供された文字セットを保持します。- パラメーター:
defaultQos
- デフォルトの QoS。qosProcessor
- QOS を決定するためのメッセージプロセッサー。defaultRetained
- デフォルトは保持されます。retainedProcessor
- 保持されたフラグを判別するためのメッセージプロセッサー。charset
- 送信文字列ペイロードをbyte[]
に変換し、受信byte[]
を文字列に変換するために使用される文字セット(payloadAdBytes
が true の場合を除く)。- 導入:
- 5.0
メソッドの詳細
setBeanFactory
- 次で指定:
- インターフェース
BeanFactoryAware
のsetBeanFactory
getBeanFactory
getMessageBuilderFactory
setPayloadAsBytes
public void setPayloadAsBytes(boolean payloadAsBytes) コンバーターがメッセージペイロードを文字列に変換してはならない場合は True。BytesMessageMapper
が提供されている場合は無視されます。- パラメーター:
payloadAsBytes
- 設定する payloadAsBytes。- 関連事項:
isPayloadAsBytes
public boolean isPayloadAsBytes()setBytesMessageMapper
byte[] をマッピングするときに使用するBytesMessageMapper
を設定します。BytesMessageMapper
が提供されている場合、setPayloadAsBytes(boolean)
は無視されます。- パラメーター:
bytesMessageMapper
- マッパー。- 導入:
- 5.0
- 関連事項:
toMessage
- 次で指定:
- インターフェース
MessageConverter
のtoMessage
toMessageBuilder
public AbstractIntegrationMessageBuilder<?> toMessageBuilder(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) インターフェースからコピーされた説明:MqttMessageConverter
メッセージビルダーに変換します。- 次で指定:
- インターフェース
MqttMessageConverter
のtoMessageBuilder
- パラメーター:
topic
- トピック。mqttMessage
- MQTT メッセージ。- 戻り値:
- ビルダー。
fromMessage
public org.eclipse.paho.client.mqttv3.MqttMessage fromMessage(Message<?> message, ClassSE<?> targetClass) - 次で指定:
- インターフェース
MessageConverter
のfromMessage
mqttBytesToPayload
サブクラスはこのメソッドをオーバーライドして、byte[] をペイロードに変換できます。デフォルトの実装では、String(デフォルト)または byte[] が作成されます。- パラメーター:
mqttMessage
- 受信メッセージ。- 戻り値:
- Spring 統合メッセージのペイロード
messageToMqttBytes
サブクラスはこのメソッドをオーバーライドして、ペイロードを byte[] に変換できます。デフォルトの実装は、byte[] または String ペイロードを受け入れます。BytesMessageMapper
が提供されている場合、byte[] への変換が委譲されるため、BytesMessageMapper
が処理できるすべてのペイロードがサポートされます。- パラメーター:
message
- 送信メッセージ。- 戻り値:
- MQTT メッセージのペイロードとなる byte[]。