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

barrier

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

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