spring-integration-core/org.springframework.integration.dsl/KotlinIntegrationFlowDefinition/barrier

barrier

fun barrier(timeout: Long, barrierConfigurer: BarrierSpec.() -> Unit = {})

Populate a org.springframework.integration.aggregator.BarrierMessageHandler instance for provided timeout and options from BarrierSpec and endpoint options from GenericEndpointSpec.