public class HeaderEnricherSpec extends ConsumerEndpointSpec<HeaderEnricherSpec,MessageTransformingHandler>
| 修飾子と型 | フィールドと説明 |
|---|---|
protected HeaderEnricher | headerEnricher |
protected MapSE<StringSE, HeaderValueMessageProcessor<?>> | headerToAdd |
adviceChaincomponentsToRegister, endpointFactoryBean, handlerPARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子 | コンストラクターと説明 |
|---|---|
protected | HeaderEnricherSpec() |
advice, async, autoStartup, customizeMonoReply, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactionalassertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEprotected final MapSE<StringSE,HeaderValueMessageProcessor<?>> headerToAdd
protected final HeaderEnricher headerEnricher
public HeaderEnricherSpec defaultOverwrite(boolean defaultOverwrite)
defaultOverwrite - defaultOverwrite。HeaderEnricher.setDefaultOverwrite(boolean)public HeaderEnricherSpec shouldSkipNulls(boolean shouldSkipNulls)
shouldSkipNulls - shouldSkipNulls。HeaderEnricher.setShouldSkipNulls(boolean)public HeaderEnricherSpec messageProcessor(MessageProcessor<?> messageProcessor)
MessageProcessor を構成します。プロセッサーは、ヘッダー名と値の MapSE を返す必要があります。これらは、構成された個々のヘッダー仕様を評価する前に、受信メッセージヘッダーに追加されます。messageProcessor - messageProcessor。HeaderEnricher.setMessageProcessor(MessageProcessor)public HeaderEnricherSpec messageProcessor(StringSE expression)
MapSE に評価される ExpressionEvaluatingMessageProcessor を構成します。これらは、構成された個々のヘッダー仕様を評価する前に、受信メッセージヘッダーに追加されます。expression - 表現。messageProcessor(MessageProcessor)public HeaderEnricherSpec messageProcessor(StringSE beanName, StringSE methodName)
MethodInvokingMessageProcessor を構成します。メソッドはヘッダーの MapSE を返す必要があります。これらは、構成された個々のヘッダー仕様を評価する前に、受信メッセージヘッダーに追加されます。beanName - Bean の名前。methodName - メソッド名。messageProcessor(MessageProcessor)public HeaderEnricherSpec headers(MapBuilder<?,StringSE,ObjectSE> headers)
MapBuilder からヘッダー仕様を追加します。; マップ値が Expression の場合、メッセージヘッダーが強化された実行時に評価されます。それ以外の場合、値は単にヘッダーに追加されます。マップから派生したヘッダーは、defaultOverwrite(boolean) が真でない限り、既存のヘッダーを上書きしません。headers - ヘッダーマップビルダー。public HeaderEnricherSpec headers(MapBuilder<?,StringSE,ObjectSE> headers, BooleanSE overwrite)
MapBuilder からヘッダー仕様を追加します。; マップ値が Expression の場合、メッセージヘッダーが強化された実行時に評価されます。それ以外の場合、値は単にヘッダーに追加されます。headers - ヘッダーマップビルダー。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec headers(MapSE<StringSE,ObjectSE> headers)
MapSE からヘッダー仕様を追加します。; マップ値が Expression の場合、メッセージヘッダーが強化された実行時に評価されます。それ以外の場合、値は単にヘッダーに追加されます。マップから派生したヘッダーは、defaultOverwrite(boolean) が真でない限り、既存のヘッダーを上書きしません。headers - ヘッダービルダー。public HeaderEnricherSpec headers(MapSE<StringSE,ObjectSE> headers, BooleanSE overwrite)
MapSE からヘッダー仕様を追加します。; マップ値が Expression の場合、メッセージヘッダーが強化された実行時に評価されます。それ以外の場合、値は単にヘッダーに追加されます。headers - ヘッダービルダー。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec headerExpressions(MapBuilder<?,StringSE,StringSE> headers)
MapBuilder からヘッダー仕様を追加します。; MapSE 値は、メッセージヘッダーが強化された実行時に評価される SpEL 式の文字列表現である必要があります。マップから派生したヘッダーは、defaultOverwrite(boolean) が真でない限り、既存のヘッダーを上書きしません。headers - ヘッダーマップビルダー。public HeaderEnricherSpec headerExpressions(MapBuilder<?,StringSE,StringSE> headers, BooleanSE overwrite)
MapBuilder からヘッダー仕様を追加します。; MapSE 値は、メッセージヘッダーが強化された実行時に評価される SpEL 式の文字列表現である必要があります。headers - ヘッダーマップビルダー。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec headerExpressions(java.util.function.ConsumerSE<StringStringMapBuilder> configurer)
StringStringMapBuilder を受信するコンシューマーコールバックを介してヘッダー仕様を追加します。MapSE 値は、メッセージヘッダーが強化された実行時に評価される SpEL 式の文字列表現である必要があります。マップから派生したヘッダーは、defaultOverwrite(boolean) が真でない限り、既存のヘッダーを上書きしません。通常、JDK8 ラムダで使用されます。
.enrichHeaders(s -> s.headerExpressions(c -> c
.put(MailHeaders.SUBJECT, "payload.subject")
.put(MailHeaders.FROM, "payload.from[0].toString()")))
configurer - コンフィギュレーター。public HeaderEnricherSpec headerExpressions(java.util.function.ConsumerSE<StringStringMapBuilder> configurer, BooleanSE overwrite)
StringStringMapBuilder を受信するコンシューマーコールバックを介してヘッダー仕様を追加します。MapSE 値は、メッセージヘッダーが強化された実行時に評価される SpEL 式の文字列表現である必要があります。通常、JDK8 ラムダで使用されます。
.enrichHeaders(s -> s.headerExpressions(c -> c
.put(MailHeaders.SUBJECT, "payload.subject")
.put(MailHeaders.FROM, "payload.from[0].toString()"), true))
configurer - コンフィギュレーター。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec headerExpressions(MapSE<StringSE,StringSE> headers)
MapSE 値は、メッセージヘッダーが強化された実行時に評価される SpEL 式の文字列表現である必要があります。マップから派生したヘッダーは、defaultOverwrite(boolean) が真でない限り、既存のヘッダーを上書きしません。headers - ヘッダー。public HeaderEnricherSpec headerExpressions(MapSE<StringSE,StringSE> headers, BooleanSE overwrite)
MapSE 値は、メッセージヘッダーが強化された実行時に評価される SpEL 式の文字列表現である必要があります。headers - ヘッダー。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec correlationId(ObjectSE correlationId)
IntegrationMessageHeaderAccessor.CORRELATION_ID ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。correlationId - IntegrationMessageHeaderAccessor.CORRELATION_ID のヘッダー値。public HeaderEnricherSpec correlationId(ObjectSE correlationId, BooleanSE overwrite)
IntegrationMessageHeaderAccessor.CORRELATION_ID ヘッダーを追加します。correlationId - IntegrationMessageHeaderAccessor.CORRELATION_ID のヘッダー値。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec correlationIdExpression(StringSE correlationIdExpression)
Expression 評価結果である IntegrationMessageHeaderAccessor.CORRELATION_ID ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。correlationIdExpression - IntegrationMessageHeaderAccessor.CORRELATION_ID ヘッダーの式。public HeaderEnricherSpec correlationIdExpression(StringSE correlationIdExpression, BooleanSE overwrite)
Expression 評価結果である IntegrationMessageHeaderAccessor.CORRELATION_ID ヘッダーを追加します。correlationIdExpression - IntegrationMessageHeaderAccessor.CORRELATION_ID ヘッダーの式。overwrite - true の場合、既存のヘッダーを上書きします。public <P> HeaderEnricherSpec correlationIdFunction(java.util.function.FunctionSE<Message<P>,ObjectSE> correlationIdFunction)
FunctionSE コールバックを呼び出して値を取得する IntegrationMessageHeaderAccessor.CORRELATION_ID ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。P - ペイロード型。correlationIdFunction - 関数。FunctionExpressionpublic <P> HeaderEnricherSpec correlationIdFunction(java.util.function.FunctionSE<Message<P>,?> correlationIdFunction, BooleanSE overwrite)
FunctionSE コールバックを呼び出して値を取得する IntegrationMessageHeaderAccessor.CORRELATION_ID ヘッダーを追加します。P - ペイロード型。correlationIdFunction - 関数。overwrite - true の場合、既存のヘッダーを上書きします。FunctionExpressionpublic HeaderEnricherSpec replyChannel(ObjectSE replyChannel)
MessageHeaders.REPLY_CHANNEL ヘッダーを追加します: Bean の名前またはインスタンス。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。replyChannel - MessageHeaders.REPLY_CHANNEL のヘッダー値。public HeaderEnricherSpec replyChannel(ObjectSE replyChannel, BooleanSE overwrite)
MessageHeaders.REPLY_CHANNEL ヘッダーを追加します: Bean の名前またはインスタンス。replyChannel - MessageHeaders.REPLY_CHANNEL のヘッダー値。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec replyChannelExpression(StringSE replyChannelExpression)
Expression 評価結果である MessageHeaders.REPLY_CHANNEL ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。replyChannelExpression - MessageHeaders.REPLY_CHANNEL ヘッダーの式。public HeaderEnricherSpec replyChannelExpression(StringSE replyChannelExpression, BooleanSE overwrite)
Expression 評価結果である MessageHeaders.REPLY_CHANNEL ヘッダーを追加します。replyChannelExpression - MessageHeaders.REPLY_CHANNEL ヘッダーの式。overwrite - true の場合、既存のヘッダーを上書きします。public <P> HeaderEnricherSpec replyChannelFunction(java.util.function.FunctionSE<Message<P>,ObjectSE> replyChannelFunction)
FunctionSE コールバックを呼び出して値を取得する MessageHeaders.REPLY_CHANNEL ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。P - ペイロード型。replyChannelFunction - 関数。FunctionExpressionpublic <P> HeaderEnricherSpec replyChannelFunction(java.util.function.FunctionSE<Message<P>,?> replyChannelFunction, BooleanSE overwrite)
FunctionSE コールバックを呼び出して値を取得する MessageHeaders.REPLY_CHANNEL ヘッダーを追加します。P - ペイロード型。replyChannelFunction - 関数。overwrite - true の場合、既存のヘッダーを上書きします。FunctionExpressionpublic HeaderEnricherSpec errorChannel(ObjectSE errorChannel)
MessageHeaders.ERROR_CHANNEL ヘッダーを追加します: Bean の名前またはインスタンス。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。errorChannel - MessageHeaders.ERROR_CHANNEL のヘッダー値。public HeaderEnricherSpec errorChannel(ObjectSE errorChannel, BooleanSE overwrite)
MessageHeaders.ERROR_CHANNEL ヘッダーを追加します: Bean の名前またはインスタンス。errorChannel - MessageHeaders.ERROR_CHANNEL のヘッダー値。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec errorChannelExpression(StringSE errorChannelExpression)
Expression 評価結果である MessageHeaders.ERROR_CHANNEL ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。errorChannelExpression - MessageHeaders.ERROR_CHANNEL ヘッダーの式。public HeaderEnricherSpec errorChannelExpression(StringSE errorChannelExpression, BooleanSE overwrite)
Expression 評価結果である MessageHeaders.ERROR_CHANNEL ヘッダーを追加します。errorChannelExpression - MessageHeaders.ERROR_CHANNEL ヘッダーの式。overwrite - true の場合、既存のヘッダーを上書きします。public <P> HeaderEnricherSpec errorChannelFunction(java.util.function.FunctionSE<Message<P>,ObjectSE> errorChannelFunction)
FunctionSE コールバックを呼び出して値を取得する MessageHeaders.ERROR_CHANNEL ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。P - ペイロード型。errorChannelFunction - 関数。FunctionExpressionpublic <P> HeaderEnricherSpec errorChannelFunction(java.util.function.FunctionSE<Message<P>,?> errorChannelFunction, BooleanSE overwrite)
FunctionSE コールバックを呼び出して値を取得する MessageHeaders.ERROR_CHANNEL ヘッダーを追加します。P - ペイロード型。errorChannelFunction - 関数。overwrite - true の場合、既存のヘッダーを上書きします。FunctionExpressionpublic HeaderEnricherSpec priority(NumberSE priority)
IntegrationMessageHeaderAccessor.PRIORITY ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。priority - IntegrationMessageHeaderAccessor.PRIORITY のヘッダー値。public HeaderEnricherSpec priority(NumberSE priority, BooleanSE overwrite)
IntegrationMessageHeaderAccessor.PRIORITY ヘッダーを追加します。priority - IntegrationMessageHeaderAccessor.PRIORITY のヘッダー値。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec priorityExpression(StringSE priorityExpression)
Expression 評価結果である IntegrationMessageHeaderAccessor.PRIORITY ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。priorityExpression - IntegrationMessageHeaderAccessor.PRIORITY ヘッダーの式。public HeaderEnricherSpec priorityExpression(StringSE priorityExpression, BooleanSE overwrite)
Expression 評価結果である IntegrationMessageHeaderAccessor.PRIORITY ヘッダーを追加します。priorityExpression - IntegrationMessageHeaderAccessor.PRIORITY ヘッダーの式。overwrite - true の場合、既存のヘッダーを上書きします。public <P> HeaderEnricherSpec priorityFunction(java.util.function.FunctionSE<Message<P>,ObjectSE> priorityFunction)
FunctionSE コールバックを呼び出して値を取得する IntegrationMessageHeaderAccessor.PRIORITY ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。P - ペイロード型。priorityFunction - 関数。FunctionExpressionpublic <P> HeaderEnricherSpec priorityFunction(java.util.function.FunctionSE<Message<P>,?> priorityFunction, BooleanSE overwrite)
FunctionSE コールバックを呼び出して値を取得する IntegrationMessageHeaderAccessor.PRIORITY ヘッダーを追加します。P - ペイロード型。priorityFunction - 関数。overwrite - true の場合、既存のヘッダーを上書きします。FunctionExpressionpublic HeaderEnricherSpec expirationDate(ObjectSE expirationDate)
IntegrationMessageHeaderAccessor.EXPIRATION_DATE ヘッダーを追加します: DateSE または long。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。expirationDate - IntegrationMessageHeaderAccessor.EXPIRATION_DATE のヘッダー値。public HeaderEnricherSpec expirationDate(ObjectSE expirationDate, BooleanSE overwrite)
IntegrationMessageHeaderAccessor.EXPIRATION_DATE ヘッダーを追加します。expirationDate - IntegrationMessageHeaderAccessor.EXPIRATION_DATE のヘッダー値。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec expirationDateExpression(StringSE expirationDateExpression)
Expression 評価結果である IntegrationMessageHeaderAccessor.EXPIRATION_DATE ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。expirationDateExpression - IntegrationMessageHeaderAccessor.EXPIRATION_DATE ヘッダーの式。public HeaderEnricherSpec expirationDateExpression(StringSE expirationDateExpression, BooleanSE overwrite)
Expression 評価結果である IntegrationMessageHeaderAccessor.EXPIRATION_DATE ヘッダーを追加します。expirationDateExpression - IntegrationMessageHeaderAccessor.EXPIRATION_DATE ヘッダーの式。overwrite - true の場合、既存のヘッダーを上書きします。public <P> HeaderEnricherSpec expirationDateFunction(java.util.function.FunctionSE<Message<P>,ObjectSE> expirationDateFunction)
FunctionSE コールバックを呼び出して値を取得する IntegrationMessageHeaderAccessor.EXPIRATION_DATE ヘッダーを追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。P - ペイロード型。expirationDateFunction - 関数。FunctionExpressionpublic <P> HeaderEnricherSpec expirationDateFunction(java.util.function.FunctionSE<Message<P>,?> expirationDateFunction, BooleanSE overwrite)
FunctionSE コールバックを呼び出して値を取得する IntegrationMessageHeaderAccessor.EXPIRATION_DATE ヘッダーを追加します。P - ペイロード型。expirationDateFunction - 関数。overwrite - true の場合、既存のヘッダーを上書きします。FunctionExpressionpublic HeaderEnricherSpec routingSlip(ObjectSE... routingSlipPath)
IntegrationMessageHeaderAccessor.ROUTING_SLIP ヘッダーを追加します。可能な値は次のとおりです。MessageChannel インスタンス。MessageChannel Bean 名。RoutingSlipRouteStrategy インスタンス。RoutingSlipRouteStrategy Bean 名。MessageChannel または RoutingSlipRouteStrategy に対して評価する必要がある SpEL 式の String。defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。routingSlipPath - IntegrationMessageHeaderAccessor.ROUTING_SLIP のヘッダー値。public HeaderEnricherSpec routingSlip(BooleanSE overwrite, ObjectSE... routingSlipPath)
IntegrationMessageHeaderAccessor.ROUTING_SLIP ヘッダーを追加します。可能な値は次のとおりです。MessageChannel インスタンス。MessageChannel Bean 名。RoutingSlipRouteStrategy インスタンス。RoutingSlipRouteStrategy Bean 名。MessageChannel または RoutingSlipRouteStrategy に対して評価する必要がある SpEL 式の String。overwrite - true の場合、既存のヘッダーを上書きします。routingSlipPath - IntegrationMessageHeaderAccessor.ROUTING_SLIP のヘッダー値。public <V> HeaderEnricherSpec header(StringSE name, V value)
defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。V - 値の型。name - ヘッダー名。value - ヘッダー値(Expression ではありません)。public <V> HeaderEnricherSpec header(StringSE name, V value, BooleanSE overwrite)
V - 値の型。name - ヘッダー名。value - ヘッダー値(Expression ではありません)。overwrite - true の場合、既存のヘッダーを上書きします。public HeaderEnricherSpec headerExpression(StringSE name, StringSE expression)
Expression の文字列表現である単一のヘッダー指定を追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。name - ヘッダー名。expression - 表現。public HeaderEnricherSpec headerExpression(StringSE name, StringSE expression, BooleanSE overwrite)
Expression の文字列表現である単一のヘッダー指定を追加します。name - ヘッダー名。expression - 表現。overwrite - true の場合、既存のヘッダーを上書きします。public <P> HeaderEnricherSpec headerFunction(StringSE name, java.util.function.FunctionSE<Message<P>,?> function)
FunctionSE コールバックを呼び出して値を取得する単一のヘッダー指定を追加します。ヘッダーが存在する場合、defaultOverwrite(boolean) が true でない限り、ヘッダーは上書きされません。P - ペイロード型。name - ヘッダー名。function - 関数。FunctionExpressionpublic <P> HeaderEnricherSpec headerFunction(StringSE name, java.util.function.FunctionSE<Message<P>,?> function, BooleanSE overwrite)
FunctionSE コールバックを呼び出して値を取得する単一のヘッダー指定を追加します。P - ペイロード型。name - ヘッダー名。function - 関数。overwrite - true の場合、既存のヘッダーを上書きします。FunctionExpressionpublic <V> HeaderEnricherSpec header(StringSE headerName, HeaderValueMessageProcessor<V> headerValueMessageProcessor)
HeaderValueMessageProcessor を呼び出して値を取得する単一のヘッダー仕様を追加します。V - 値の型。headerName - ヘッダー名。headerValueMessageProcessor - メッセージプロセッサー。public HeaderEnricherSpec headerChannelsToString()
HeaderChannelRegistrypublic HeaderEnricherSpec headerChannelsToString(StringSE timeToLiveExpression)
timeToLiveExpression - マッピングがレジストリに残る最小時間。HeaderChannelRegistryprotected reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,MessageTransformingHandler> doGet()
ConsumerEndpointSpec<HeaderEnricherSpec, MessageTransformingHandler> の doGet