Uses of Class
org.springframework.integration.dsl.AggregatorSpec
Packages that use AggregatorSpec
Package
Description
Root package of the Spring Integration Java DSL.
-
Uses of AggregatorSpec in org.springframework.integration.dsl
Methods in org.springframework.integration.dsl that return AggregatorSpecModifier 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.Method parameters in org.springframework.integration.dsl with type arguments of type AggregatorSpecModifier 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.