spring-integration / org.springframework.integration.dsl / KotlinIntegrationFlowDefinition / aggregate

aggregate

fun aggregate(aggregator: AggregatorSpec.() -> Unit = {}): Unit

Populate the AggregatingMessageHandler with provided options from AggregatorSpec. In addition accept options for the integration endpoint using GenericEndpointSpec.