amqp-client/dev.kourier.amqp.channel/flow

flow

suspend fun AMQPChannel.flow(controlledFlow: ControlledFlow): AMQPResponse.Channel.Flowed

Send a flow message to broker using a ControlledFlow instance.

Return

The flow response.

Parameters

controlledFlow

The ControlledFlow instance containing the flow properties.

suspend fun AMQPChannel.flow(block: ControlledFlowBuilder.() -> Unit): AMQPResponse.Channel.Flowed

Send a flow message to broker using a ControlledFlowBuilder block.

Return

The flow response.

Parameters

block

The block to configure the ControlledFlowBuilder.