Uses of Class
org.springframework.integration.dsl.AggregatorSpec
Package
Description
Root package of the Spring Integration Java DSL.
-
Uses of AggregatorSpec in org.springframework.integration.dsl
Modifier and TypeMethodDescriptionAggregatorSpec.expireGroupsUponCompletion
(boolean expireGroupsUponCompletion) AggregatorSpec.headersFunction
(Function<MessageGroup, Map<String, Object>> headersFunction) Configure aFunction
to merge and compute headers for reply based on the completedMessageGroup
.AggregatorSpec.outputExpression
(String expression) An expression to determine the output message from the released group.AggregatorSpec.outputProcessor
(MessageGroupProcessor outputProcessor) A processor to determine the output message from the released group.Configure the handler withMethodInvokingCorrelationStrategy
andMethodInvokingReleaseStrategy
using the target object which should have methods annotated appropriately for each function.Configure the handler withMethodInvokingCorrelationStrategy
andMethodInvokingReleaseStrategy
using the target object which should have methods annotated appropriately for each function.Modifier and TypeMethodDescriptionBaseIntegrationFlowDefinition.aggregate
(Consumer<AggregatorSpec> aggregator) Populate theAggregatingMessageHandler
with provided options fromAggregatorSpec
.BaseIntegrationFlowDefinition.scatterGather
(MessageChannel scatterChannel, Consumer<AggregatorSpec> gatherer) Populate aScatterGatherHandler
to the current integration flow position based on the providedMessageChannel
for scattering function andAggregatorSpec
for gathering function.BaseIntegrationFlowDefinition.scatterGather
(MessageChannel scatterChannel, Consumer<AggregatorSpec> gatherer, Consumer<ScatterGatherSpec> scatterGather) Populate aScatterGatherHandler
to the current integration flow position based on the providedMessageChannel
for scattering function andAggregatorSpec
for gathering function.