クラス 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 に、または Spring Integration MessageHeaders からコピーします。AMQP MessageProperties 内のユーザー定義ヘッダーは、'requestHeaderNames' や 'replyHeaderNames' で明示的に識別されない限り、AMQP メッセージに、または AMQP メッセージからコピーされることはありません (AbstractHeaderMapper.setRequestHeaderNames(String[]) と AbstractHeaderMapper.setReplyHeaderNames(String[]) }、および AMQP アダプターの 'mapped-request-headers' 属性と 'mapped-reply-headers' 属性を参照)。すべてのユーザー定義ヘッダーをコピーする必要がある場合は、ワイルドカード文字 '*' を使用します。

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

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

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

    • DefaultAmqpHeaderMapper

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

  • 方法の詳細

    • extractStandardHeaders

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

    • extractUserDefinedHeaders

      protected MapSE<StringSE, @Nullable 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, @Nullable 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