vertx / io.vertx.rxjava.rabbitmq / RabbitMQClient / rxWaitForConfirms

# rxWaitForConfirms

`open fun rxWaitForConfirms(): Single<Void>`

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.

Return

`open fun rxWaitForConfirms(timeout: Long): Single<Void>`

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` -

Return