public class DefaultPahoMessageConverter extends ObjectSE implements MqttMessageConverter, BeanFactoryAware
| コンストラクターと説明 |
|---|
DefaultPahoMessageConverter() デフォルトのオプション(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 | getBeanFactory() |
protected MessageBuilderFactory | getMessageBuilderFactory() |
boolean | isPayloadAsBytes() |
protected byte[] | messageToMqttBytes(Message<?> message) サブクラスはこのメソッドをオーバーライドして、ペイロードを byte[] に変換できます。 |
protected ObjectSE | mqttBytesToPayload(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) サブクラスはこのメソッドをオーバーライドして、byte[] をペイロードに変換できます。 |
void | setBeanFactory(BeanFactory beanFactory) |
void | setBytesMessageMapper(BytesMessageMapper bytesMessageMapper)byte[] をマッピングするときに使用する BytesMessageMapper を設定します。 |
void | setPayloadAsBytes(boolean payloadAsBytes) コンバーターがメッセージペイロードを文字列に変換してはならない場合は True。 |
Message<?> | toMessage(ObjectSE mqttMessage, MessageHeaders headers) |
Message<?> | toMessage(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) メッセージに変換します。 |
AbstractIntegrationMessageBuilder<?> | toMessageBuilder(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) メッセージビルダーに変換します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEdefaultQosProcessor, defaultRetainedProcessorpublic DefaultPahoMessageConverter()
public DefaultPahoMessageConverter(int defaultQos,
boolean defaultRetained)byte[] に、受信 byte[] を文字列に変換するための UTF-8 文字セットを保持します(payloadAdBytes が true でない場合)。defaultQos - デフォルトの QoS。defaultRetained - デフォルトは保持されます。public DefaultPahoMessageConverter(StringSE charset)
charset - 送信文字列ペイロードを byte[] に変換し、受信 byte[] を文字列に変換するために使用される文字セット(payloadAdBytes が true の場合を除く)。public DefaultPahoMessageConverter(int defaultQos,
boolean defaultRetained,
StringSE charset)defaultQos - デフォルトの QoS。defaultRetained - デフォルトは保持されます。charset - 送信文字列ペイロードを byte[] に変換し、受信 byte[] を文字列に変換するために使用される文字セット(payloadAdBytes が true の場合を除く)。public DefaultPahoMessageConverter(int defaultQos,
MessageProcessor<IntegerSE> qosProcessor,
boolean defaultRetained,
MessageProcessor<BooleanSE> retainedProcessor)byte[] に、受信 byte[] を文字列に変換するための UTF-8 文字セットを使用して送信メッセージを作成するコンバーターを構築します(payloadAdBytes が true でない場合)。defaultQos - デフォルトの QoS。qosProcessor - QOS を決定するためのメッセージプロセッサー。defaultRetained - デフォルトは保持されます。retainedProcessor - 保持されたフラグを判別するためのメッセージプロセッサー。public DefaultPahoMessageConverter(int defaultQos,
MessageProcessor<IntegerSE> qosProcessor,
boolean defaultRetained,
MessageProcessor<BooleanSE> retainedProcessor,
StringSE charset)defaultQos - デフォルトの QoS。qosProcessor - QOS を決定するためのメッセージプロセッサー。defaultRetained - デフォルトは保持されます。retainedProcessor - 保持されたフラグを判別するためのメッセージプロセッサー。charset - 送信文字列ペイロードを byte[] に変換し、受信 byte[] を文字列に変換するために使用される文字セット(payloadAdBytes が true の場合を除く)。public final void setBeanFactory(BeanFactory beanFactory)
BeanFactoryAware の setBeanFactory protected BeanFactory getBeanFactory()
protected MessageBuilderFactory getMessageBuilderFactory()
public void setPayloadAsBytes(boolean payloadAsBytes)
BytesMessageMapper が提供されている場合は無視されます。payloadAsBytes - 設定する payloadAsBytes。setBytesMessageMapper(BytesMessageMapper)public boolean isPayloadAsBytes()
public void setBytesMessageMapper(BytesMessageMapper bytesMessageMapper)
BytesMessageMapper を設定します。BytesMessageMapper が提供されている場合、setPayloadAsBytes(boolean) は無視されます。bytesMessageMapper - マッパー。setPayloadAsBytes(boolean)public Message<?> toMessage(ObjectSE mqttMessage, MessageHeaders headers)
MessageConverter の toMessage public Message<?> toMessage(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
MqttMessageConverterMqttMessageConverter の toMessage topic - トピック。mqttMessage - MQTT メッセージ。public AbstractIntegrationMessageBuilder<?> toMessageBuilder(StringSE topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
MqttMessageConverterMqttMessageConverter の toMessageBuilder topic - トピック。mqttMessage - MQTT メッセージ。public org.eclipse.paho.client.mqttv3.MqttMessage fromMessage(Message<?> message, ClassSE<?> targetClass)
MessageConverter の fromMessage protected ObjectSE mqttBytesToPayload(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
mqttMessage - 受信メッセージ。protected byte[] messageToMqttBytes(Message<?> message)
BytesMessageMapper が提供されている場合、byte[] への変換が委譲されるため、BytesMessageMapper が処理できるすべてのペイロードがサポートされます。message - 送信メッセージ。