パッケージ org.springframework.amqp.support.converter

クラス MessagingMessageConverter

java.lang.ObjectSE
org.springframework.amqp.support.converter.MessagingMessageConverter
実装されたすべてのインターフェース:
MessageConverter, InitializingBean
既知の直属サブクラス
MessagingMessageListenerAdapter.MessagingMessageConverterAdapter
public class MessagingMessageConverter extends ObjectSE implements MessageConverter, InitializingBean
Message をメッセージング抽象化から Message へ、またはその逆に変換します。これには、ペイロードの基礎となる MessageConverter と AmqpHeaderMapper を使用して、AMQP ヘッダーを標準メッセージヘッダーとの間でマッピングします。

inbound フラグは、ヘッダーのマッピング方法を決定します。true (デフォルト) の場合、呼び出し元は受信リスナーです (つまり、AMQP メッセージの解析はリクエストと見なされます)。

導入:
1.4
作成者:
Stephane Nicoll

  • コンストラクターの詳細

    • MessagingMessageConverter

      public MessagingMessageConverter()
      受信 ハンドラー用の既定のペイロードコンバーターを使用してインスタンスを作成します。
      関連事項:

    • MessagingMessageConverter

      public MessagingMessageConverter(MessageConverter payloadConverter, AmqpHeaderMapper headerMapper)
      指定されたペイロードコンバーターとヘッダーマッパーを使用してインスタンスを作成します。
      パラメーター:
      payloadConverter - payload のターゲット MessageConverter。
      headerMapper - AMQP ヘッダーを MessageHeaders にマップする AmqpHeaderMapper。

  • メソッドの詳細

    • setPayloadConverter

      public void setPayloadConverter(MessageConverter payloadConverter)
      ペイロードの変換に使用する MessageConverter を設定します。
      パラメーター:
      payloadConverter - payload のターゲット MessageConverter。

    • setHeaderMapper

      public void setHeaderMapper(AmqpHeaderMapper headerMapper)
      AMQP ヘッダーを標準メッセージヘッダーとの間でマッピングするために使用する AmqpHeaderMapper を設定します。
      パラメーター:
      headerMapper - AMQP ヘッダーを MessageHeaders にマップする AmqpHeaderMapper。

    • getHeaderMapper

      public AmqpHeaderMapper getHeaderMapper()

    • afterPropertiesSet

      public void afterPropertiesSet()
      次で指定:
      インターフェース InitializingBean の afterPropertiesSet 

    • toMessage

      public Message toMessage(ObjectSE object, MessageProperties messageProperties) throws MessageConversionException
      インターフェースからコピーされた説明: MessageConverter
      Java オブジェクトをメッセージに変換します。
      次で指定:
      インターフェース MessageConverter の toMessage 
      パラメーター:
      object - 変換するオブジェクト
      messageProperties - メッセージのプロパティ。
      戻り値:
      メッセージ
      例外:
      MessageConversionException - 変換に失敗した場合

    • fromMessage

      public ObjectSE fromMessage(Message message) throws MessageConversionException
      インターフェースからコピーされた説明: MessageConverter
      Message から Java オブジェクトに変換します。
      次で指定:
      インターフェース MessageConverter の fromMessage 
      パラメーター:
      message - 変換するメッセージ
      戻り値:
      変換された Java オブジェクト
      例外:
      MessageConversionException - 変換に失敗した場合

    • extractPayload

      protected ObjectSE extractPayload(Message message)
      指定された Message のペイロードを抽出します。
      パラメーター:
      message - payload を抽出する AMQP メッセージ。
      戻り値:
      抽出された payload。