vertx / io.vertx.kotlin.rabbitmq / io.vertx.rabbitmq.RabbitMQClient / waitForConfirmsAwait

waitForConfirmsAwait

suspend fun RabbitMQClient.waitForConfirmsAwait(): Unit

Wait until all messages published since the last call have been either ack'd or nack'd by the broker. This will incur slight performance loss at the expense of higher write consistency. If desired, multiple calls to basicPublish() can be batched before confirming.

Parameters

resultHandler -

suspend fun RabbitMQClient.waitForConfirmsAwait(timeout: Long): Unit

Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses. If the timeout expires a TimeoutException is thrown.

Parameters

timeout -

resultHandler -