Uses of Class
org.springframework.integration.dsl.HeaderEnricherSpec
Package
Description
Root package of the Spring Integration Java DSL.
-
Uses of HeaderEnricherSpec in org.springframework.integration.dsl
Modifier and TypeMethodDescriptionHeaderEnricherSpec.correlationId
(Object correlationId) Add aIntegrationMessageHeaderAccessor.CORRELATION_ID
header.HeaderEnricherSpec.correlationId
(Object correlationId, Boolean overwrite) Add aIntegrationMessageHeaderAccessor.CORRELATION_ID
header.HeaderEnricherSpec.correlationIdExpression
(String correlationIdExpression) Add aIntegrationMessageHeaderAccessor.CORRELATION_ID
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.correlationIdExpression
(String correlationIdExpression, Boolean overwrite) Add aIntegrationMessageHeaderAccessor.CORRELATION_ID
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.correlationIdFunction
(Function<Message<P>, ?> correlationIdFunction, Boolean overwrite) Add aIntegrationMessageHeaderAccessor.CORRELATION_ID
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.correlationIdFunction
(Function<Message<P>, Object> correlationIdFunction) Add aIntegrationMessageHeaderAccessor.CORRELATION_ID
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.defaultOverwrite
(boolean defaultOverwrite) Determine the default action to take when setting individual header specifications without an explicit 'overwrite' argument.HeaderEnricherSpec.errorChannel
(Object errorChannel) Add aMessageHeaders.ERROR_CHANNEL
header: bean name or instance.HeaderEnricherSpec.errorChannel
(Object errorChannel, Boolean overwrite) Add aMessageHeaders.ERROR_CHANNEL
header: bean name or instance.HeaderEnricherSpec.errorChannelExpression
(String errorChannelExpression) Add aMessageHeaders.ERROR_CHANNEL
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.errorChannelExpression
(String errorChannelExpression, Boolean overwrite) Add aMessageHeaders.ERROR_CHANNEL
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.errorChannelFunction
(Function<Message<P>, ?> errorChannelFunction, Boolean overwrite) Add aMessageHeaders.ERROR_CHANNEL
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.errorChannelFunction
(Function<Message<P>, Object> errorChannelFunction) Add aMessageHeaders.ERROR_CHANNEL
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.expirationDate
(Object expirationDate) HeaderEnricherSpec.expirationDate
(Object expirationDate, Boolean overwrite) Add aIntegrationMessageHeaderAccessor.EXPIRATION_DATE
header.HeaderEnricherSpec.expirationDateExpression
(String expirationDateExpression) Add aIntegrationMessageHeaderAccessor.EXPIRATION_DATE
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.expirationDateExpression
(String expirationDateExpression, Boolean overwrite) Add aIntegrationMessageHeaderAccessor.EXPIRATION_DATE
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.expirationDateFunction
(Function<Message<P>, ?> expirationDateFunction, Boolean overwrite) Add aIntegrationMessageHeaderAccessor.EXPIRATION_DATE
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.expirationDateFunction
(Function<Message<P>, Object> expirationDateFunction) Add aIntegrationMessageHeaderAccessor.EXPIRATION_DATE
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.header
(String headerName, HeaderValueMessageProcessor<V> headerValueMessageProcessor) Add a single header specification where the value is obtained by calling theHeaderValueMessageProcessor
.Add a single header specification.Add a single header specification.HeaderEnricherSpec.headerChannelsToString()
Add header specifications to automatically convert header channels (reply, error channels) to Strings and store them in a header channel registry.HeaderEnricherSpec.headerChannelsToString
(String timeToLiveExpression) Add header specifications to automatically convert header channels (reply, error channels) to Strings and store them in a header channel registry.HeaderEnricherSpec.headerExpression
(String name, String expression) Add a single header specification where the value is a String representation of a SpELExpression
.HeaderEnricherSpec.headerExpression
(String name, String expression, Boolean overwrite) Add a single header specification where the value is a String representation of a SpELExpression
.HeaderEnricherSpec.headerExpressions
(Consumer<StringStringMapBuilder> configurer) Add header specifications via the consumer callback, which receives aStringStringMapBuilder
; theMap
values must be String representations of SpEL expressions that will be evaluated at run time when the message headers are enriched.HeaderEnricherSpec.headerExpressions
(Consumer<StringStringMapBuilder> configurer, Boolean overwrite) Add header specifications via the consumer callback, which receives aStringStringMapBuilder
; theMap
values must be String representations of SpEL expressions that will be evaluated at run time when the message headers are enriched.HeaderEnricherSpec.headerExpressions
(Map<String, String> headers) Add header specifications; theMap
values must be String representations of SpEL expressions that will be evaluated at run time when the message headers are enriched.HeaderEnricherSpec.headerExpressions
(Map<String, String> headers, Boolean overwrite) Add header specifications; theMap
values must be String representations of SpEL expressions that will be evaluated at run time when the message headers are enriched.HeaderEnricherSpec.headerExpressions
(MapBuilder<?, String, String> headers) Add header specifications from theMapBuilder
; theMap
values must be String representations of SpEL expressions that will be evaluated at run time when the message headers are enriched.HeaderEnricherSpec.headerExpressions
(MapBuilder<?, String, String> headers, Boolean overwrite) Add header specifications from theMapBuilder
; theMap
values must be String representations of SpEL expressions that will be evaluated at run time when the message headers are enriched.HeaderEnricherSpec.headerFunction
(String name, Function<Message<P>, ?> function) Add a single header specification where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.headerFunction
(String name, Function<Message<P>, ?> function, Boolean overwrite) Add a single header specification where the value is obtained by invoking theFunction
callback.Add header specifications from theMap
; if a map value is anExpression
, it will be evaluated at run time when the message headers are enriched.Add header specifications from theMap
; if a map value is anExpression
, it will be evaluated at run time when the message headers are enriched.HeaderEnricherSpec.headers
(MapBuilder<?, String, Object> headers) Add header specifications from theMapBuilder
; if a map value is anExpression
, it will be evaluated at run time when the message headers are enriched.HeaderEnricherSpec.headers
(MapBuilder<?, String, Object> headers, Boolean overwrite) Add header specifications from theMapBuilder
; if a map value is anExpression
, it will be evaluated at run time when the message headers are enriched.HeaderEnricherSpec.messageProcessor
(String expression) Configure anExpressionEvaluatingMessageProcessor
that evaluates to aMap
of additional headers.HeaderEnricherSpec.messageProcessor
(String beanName, String methodName) Configure anMethodInvokingMessageProcessor
that invokes the method on the bean - the method must return aMap
of headers.HeaderEnricherSpec.messageProcessor
(MessageProcessor<?> messageProcessor) Configure an optional customMessageProcessor
for the enricher.Add aIntegrationMessageHeaderAccessor.PRIORITY
header.Add aIntegrationMessageHeaderAccessor.PRIORITY
header.HeaderEnricherSpec.priorityExpression
(String priorityExpression) Add aIntegrationMessageHeaderAccessor.PRIORITY
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.priorityExpression
(String priorityExpression, Boolean overwrite) Add aIntegrationMessageHeaderAccessor.PRIORITY
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.priorityFunction
(Function<Message<P>, ?> priorityFunction, Boolean overwrite) Add aIntegrationMessageHeaderAccessor.PRIORITY
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.priorityFunction
(Function<Message<P>, Object> priorityFunction) Add aIntegrationMessageHeaderAccessor.PRIORITY
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.replyChannel
(Object replyChannel) Add aMessageHeaders.REPLY_CHANNEL
header: bean name or instance.HeaderEnricherSpec.replyChannel
(Object replyChannel, Boolean overwrite) Add aMessageHeaders.REPLY_CHANNEL
header: bean name or instance.HeaderEnricherSpec.replyChannelExpression
(String replyChannelExpression) Add aMessageHeaders.REPLY_CHANNEL
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.replyChannelExpression
(String replyChannelExpression, Boolean overwrite) Add aMessageHeaders.REPLY_CHANNEL
header where the value is a SpELExpression
evaluation result.HeaderEnricherSpec.replyChannelFunction
(Function<Message<P>, ?> replyChannelFunction, Boolean overwrite) Add aMessageHeaders.REPLY_CHANNEL
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.replyChannelFunction
(Function<Message<P>, Object> replyChannelFunction) Add aMessageHeaders.REPLY_CHANNEL
header where the value is obtained by invoking theFunction
callback.HeaderEnricherSpec.routingSlip
(Boolean overwrite, Object... routingSlipPath) Add aIntegrationMessageHeaderAccessor.ROUTING_SLIP
header.HeaderEnricherSpec.routingSlip
(Object... routingSlipPath) Add aIntegrationMessageHeaderAccessor.ROUTING_SLIP
header.HeaderEnricherSpec.shouldSkipNulls
(boolean shouldSkipNulls) Modifier and TypeMethodDescriptionBaseIntegrationFlowDefinition.enrichHeaders
(Consumer<HeaderEnricherSpec> headerEnricherConfigurer)