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 で定義されています。
AbstractHeaderMapper.CompositeHeaderMatcher, AbstractHeaderMapper.ContentBasedHeaderMatcher, AbstractHeaderMapper.HeaderMatcher, AbstractHeaderMapper.PatternBasedHeaderMatcher, AbstractHeaderMapper.PrefixBasedMatcher, AbstractHeaderMapper.SinglePatternBasedHeaderMatcherlogger, NON_STANDARD_HEADER_NAME_PATTERN, STANDARD_REPLY_HEADER_NAME_PATTERN, STANDARD_REQUEST_HEADER_NAME_PATTERN| 修飾子 | コンストラクターと説明 |
|---|---|
protected | DefaultAmqpHeaderMapper(StringSE[] requestHeaderNames, StringSE[] replyHeaderNames) |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected MapSE<StringSE, ObjectSE> | extractStandardHeaders(MessageProperties amqpMessageProperties)AMQP MessageProperties インスタンスから「標準」ヘッダーを抽出します。 |
protected MapSE<StringSE, ObjectSE> | extractUserDefinedHeaders(MessageProperties amqpMessageProperties)AMQP MessageProperties インスタンスからユーザー定義ヘッダーを抽出します。 |
static DefaultAmqpHeaderMapper | inboundMapper() デフォルトの受信ヘッダーマッパーを作成します。 |
static StringSE[] | inboundReplyHeaders() |
static StringSE[] | inboundRequestHeaders() |
static DefaultAmqpHeaderMapper | outboundMapper() デフォルトの送信ヘッダーマッパーを作成します。 |
static StringSE[] | outboundReplyHeaders() |
static StringSE[] | outboundRequestHeaders() |
protected void | populateStandardHeaders(MapSE<StringSE, ObjectSE> allHeaders, MapSE<StringSE, ObjectSE> headers, MessageProperties amqpMessageProperties) ヘッダーを Spring Integration MessageHeaders インスタンスから AMQP メッセージの MessageProperties にマップします。 |
protected void | populateStandardHeaders(MapSE<StringSE, ObjectSE> headers, MessageProperties amqpMessageProperties) ヘッダーを Spring Integration MessageHeaders インスタンスから AMQP メッセージの MessageProperties にマップします。 |
protected void | populateUserDefinedHeader(StringSE headerName, ObjectSE headerValue, MessageProperties amqpMessageProperties) 指定されたユーザー定義ヘッダーを指定されたソースに入力します。 |
MapSE<StringSE, ObjectSE> | toHeadersFromRequest(MessageProperties source) 指定されたリクエストオブジェクトから抽象化された MessageHeaders にマップします。 |
createDefaultHeaderMatcher, createHeaderMatcher, createTargetPropertyName, fromHeadersToReply, fromHeadersToRequest, getClassLoader, getHeaderIfAvailable, getTransientHeaderNames, setBeanClassLoader, setReplyHeaderNames, setRequestHeaderNames, toHeadersFromReplycloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEfromHeadersToReply, fromHeadersToRequest, toHeadersFromReplyprotected MapSE<StringSE,ObjectSE> extractStandardHeaders(MessageProperties amqpMessageProperties)
AbstractHeaderMapper<MessageProperties> の extractStandardHeaders amqpMessageProperties - 標準ヘッダーを抽出するためのソースオブジェクト。protected MapSE<StringSE,ObjectSE> extractUserDefinedHeaders(MessageProperties amqpMessageProperties)
AbstractHeaderMapper<MessageProperties> の extractUserDefinedHeaders amqpMessageProperties - ユーザー定義のヘッダーを抽出するためのソースオブジェクト。protected void populateStandardHeaders(MapSE<StringSE,ObjectSE> headers, MessageProperties amqpMessageProperties)
AbstractHeaderMapper<MessageProperties> の populateStandardHeaders headers - 入力する標準ヘッダーのマップ。amqpMessageProperties - ヘッダーを設定するターゲットオブジェクト。protected void populateStandardHeaders(@Nullable MapSE<StringSE,ObjectSE> allHeaders, MapSE<StringSE,ObjectSE> headers, MessageProperties amqpMessageProperties)
AbstractHeaderMapper<MessageProperties> の populateStandardHeaders allHeaders - トランジェントを含むすべてのヘッダー。headers - 入力する標準ヘッダーのマップ。amqpMessageProperties - ヘッダーを設定するターゲットオブジェクト。protected void populateUserDefinedHeader(StringSE headerName, ObjectSE headerValue, MessageProperties amqpMessageProperties)
AbstractHeaderMapperAbstractHeaderMapper<MessageProperties> の populateUserDefinedHeader headerName - 入力するユーザー定義のヘッダー名。headerValue - 入力するユーザー定義のヘッダー値。amqpMessageProperties - ヘッダーを設定するターゲットオブジェクト。public MapSE<StringSE,ObjectSE> toHeadersFromRequest(MessageProperties source)
RequestReplyHeaderMapperMessageHeaders にマップします。RequestReplyHeaderMapper<MessageProperties> の toHeadersFromRequest AbstractHeaderMapper<MessageProperties> の toHeadersFromRequest source - ネイティブターゲットリクエスト public static DefaultAmqpHeaderMapper inboundMapper()
inboundRequestHeaders(), inboundReplyHeaders()public static DefaultAmqpHeaderMapper outboundMapper()
outboundRequestHeaders(), outboundReplyHeaders()public static StringSE[] inboundRequestHeaders()
public static StringSE[] inboundReplyHeaders()
public static StringSE[] outboundRequestHeaders()
public static StringSE[] outboundReplyHeaders()