barrier
fun barrier(timeout: Long, barrierConfigurer: BarrierSpec.() -> Unit = {})
Content copied to clipboard
Populate a org.springframework.integration.aggregator.BarrierMessageHandler instance for provided timeout and options from BarrierSpec and endpoint options from GenericEndpointSpec.