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

クラス DefaultAmqpHeaderMapper

java.lang.ObjectSE
org.springframework.integration.mapping.AbstractHeaderMapper<MessageProperties>
org.springframework.integration.amqp.support.DefaultAmqpHeaderMapper
実装されたすべてのインターフェース:
Aware、BeanClassLoaderAware、AmqpHeaderMapper、RequestReplyHeaderMapper<MessageProperties>
public class DefaultAmqpHeaderMapper extends AbstractHeaderMapper<MessageProperties> implements AmqpHeaderMapper
AmqpHeaderMapper のデフォルト実装。

デフォルトでは、この実装は、AMQP プロパティ（contentType など）のみを Spring Integration MessageHeaders との間でコピーします。AMQP MessageProperties 内のユーザー定義ヘッダーは、"requestHeaderNames" および / または "replyHeaderNames" （AbstractHeaderMapper.setRequestHeaderNames(String[]) および AbstractHeaderMapper.setReplyHeaderNames(String[])}、および "mapped-request-headers" および "" で明示的に識別されない限り、AMQP メッセージとの間でコピーされません。AMQP アダプターの mapped-reply-headers の属性）。すべてのユーザー定義ヘッダーをコピーする必要がある場合は、ワイルドカード文字 "*" を使用してください。

AMQP ヘッダーキーの定数は AmqpHeaders で定義されています。

導入:
2.1
作成者:
Mark Fisher, Oleg Zhurakousky, Gary Russell, Artem Bilan, Stephane Nicoll, Steve Singer

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

    • DefaultAmqpHeaderMapper

      protected DefaultAmqpHeaderMapper(StringSE[] requestHeaderNames, StringSE[] replyHeaderNames)

  • メソッドの詳細

    • extractStandardHeaders

      protected MapSE<StringSE,ObjectSE> extractStandardHeaders(MessageProperties amqpMessageProperties)
      AMQP MessageProperties インスタンスから「標準」ヘッダーを抽出します。
      次で指定:
      クラス AbstractHeaderMapper<MessageProperties> の extractStandardHeaders 
      パラメーター:
      amqpMessageProperties - 標準ヘッダーを抽出するためのソースオブジェクト。
      戻り値:
      マップされるヘッダーのマップ。

    • extractUserDefinedHeaders

      protected MapSE<StringSE,ObjectSE> extractUserDefinedHeaders(MessageProperties amqpMessageProperties)
      AMQP MessageProperties インスタンスからユーザー定義ヘッダーを抽出します。
      次で指定:
      クラス AbstractHeaderMapper<MessageProperties> の extractUserDefinedHeaders 
      パラメーター:
      amqpMessageProperties - ユーザー定義のヘッダーを抽出するためのソースオブジェクト。
      戻り値:
      マップされるヘッダーのマップ。

    • populateStandardHeaders

      protected void populateStandardHeaders(MapSE<StringSE,ObjectSE> headers, MessageProperties amqpMessageProperties)
      ヘッダーを Spring Integration MessageHeaders インスタンスから AMQP メッセージの MessageProperties にマップします。
      次で指定:
      クラス AbstractHeaderMapper<MessageProperties> の populateStandardHeaders 
      パラメーター:
      headers - 入力する標準ヘッダーのマップ。
      amqpMessageProperties - ヘッダーを設定するターゲットオブジェクト。

    • populateStandardHeaders

      protected void populateStandardHeaders(@Nullable MapSE<StringSE,ObjectSE> allHeaders, MapSE<StringSE,ObjectSE> headers, MessageProperties amqpMessageProperties)
      ヘッダーを Spring Integration MessageHeaders インスタンスから AMQP メッセージの MessageProperties にマップします。
      オーバーライド:
      クラス AbstractHeaderMapper<MessageProperties> の populateStandardHeaders 
      パラメーター:
      allHeaders - トランジェントを含むすべてのヘッダー。
      headers - 入力する標準ヘッダーのマップ。
      amqpMessageProperties - ヘッダーを設定するターゲットオブジェクト。

    • populateUserDefinedHeader

      protected void populateUserDefinedHeader(StringSE headerName, ObjectSE headerValue, MessageProperties amqpMessageProperties)
      クラスからコピーされた説明: AbstractHeaderMapper
      指定されたユーザー定義ヘッダーを指定されたソースに入力します。
      次で指定:
      クラス AbstractHeaderMapper<MessageProperties> の populateUserDefinedHeader 
      パラメーター:
      headerName - 入力するユーザー定義のヘッダー名。
      headerValue - 入力するユーザー定義のヘッダー値。
      amqpMessageProperties - ヘッダーを設定するターゲットオブジェクト。

    • toHeadersFromRequest

      public MapSE<StringSE,ObjectSE> toHeadersFromRequest(MessageProperties source)
      インターフェースからコピーされた説明: RequestReplyHeaderMapper
      指定されたリクエストオブジェクトから抽象化された MessageHeaders にマップします。
      次で指定:
      インターフェース RequestReplyHeaderMapper<MessageProperties> の toHeadersFromRequest 
      オーバーライド:
      クラス AbstractHeaderMapper<MessageProperties> の toHeadersFromRequest 
      パラメーター:
      source - ネイティブターゲットリクエスト
      戻り値:
      抽象化された MessageHeaders

    • inboundMapper

      public static DefaultAmqpHeaderMapper inboundMapper()
      デフォルトの受信ヘッダーマッパーを作成します。
      戻り値:
      マッパー。
      導入:
      4.3
      関連事項:

    • outboundMapper

      public static DefaultAmqpHeaderMapper outboundMapper()
      デフォルトの送信ヘッダーマッパーを作成します。
      戻り値:
      マッパー。
      導入:
      4.3
      関連事項:

    • inboundRequestHeaders

      public static StringSE[] inboundRequestHeaders()
      戻り値:
      受信マッパーのデフォルトのリクエストヘッダー。
      導入:
      4.3

    • inboundReplyHeaders

      public static StringSE[] inboundReplyHeaders()
      戻り値:
      受信マッパーのデフォルトの応答ヘッダー。
      導入:
      4.3

    • outboundRequestHeaders

      public static StringSE[] outboundRequestHeaders()
      戻り値:
      送信マッパーのデフォルトのリクエストヘッダー。
      導入:
      4.3

    • outboundReplyHeaders

      public static StringSE[] outboundReplyHeaders()
      戻り値:
      送信マッパーのデフォルトの応答ヘッダー。
      導入:
      4.3