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

### Extensions for io.vertx.rabbitmq.RabbitMQClient

basicAckAwait | `suspend fun RabbitMQClient.basicAckAwait(deliveryTag: Long, multiple: Boolean): JsonObject` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicAck
basicConsumerAwait | `suspend fun RabbitMQClient.basicConsumerAwait(queue: String): RabbitMQConsumer` `suspend fun RabbitMQClient.basicConsumerAwait(queue: String, options: QueueOptions): RabbitMQConsumer` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicConsumer
basicGetAwait | `suspend fun RabbitMQClient.basicGetAwait(queue: String, autoAck: Boolean): JsonObject` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicGet
basicNackAwait | `suspend fun RabbitMQClient.basicNackAwait(deliveryTag: Long, multiple: Boolean, requeue: Boolean): JsonObject` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicNack
basicPublishAwait | `suspend fun RabbitMQClient.basicPublishAwait(exchange: String, routingKey: String, message: JsonObject): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicPublish
basicQosAwait | `suspend fun RabbitMQClient.basicQosAwait(prefetchCount: Int): Unit` `suspend fun RabbitMQClient.basicQosAwait(prefetchCount: Int, global: Boolean): Unit` `suspend fun RabbitMQClient.basicQosAwait(prefetchSize: Int, prefetchCount: Int, global: Boolean): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicQos
confirmSelectAwait | `suspend fun RabbitMQClient.confirmSelectAwait(): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.confirmSelect
exchangeBindAwait | `suspend fun RabbitMQClient.exchangeBindAwait(destination: String, source: String, routingKey: String): Unit` `suspend fun RabbitMQClient.exchangeBindAwait(destination: String, source: String, routingKey: String, arguments: Map<String, Any>): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.exchangeBind
exchangeDeclareAwait | `suspend fun RabbitMQClient.exchangeDeclareAwait(exchange: String, type: String, durable: Boolean, autoDelete: Boolean): Unit` `suspend fun RabbitMQClient.exchangeDeclareAwait(exchange: String, type: String, durable: Boolean, autoDelete: Boolean, config: JsonObject): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.exchangeDeclare
exchangeDeleteAwait | `suspend fun RabbitMQClient.exchangeDeleteAwait(exchange: String): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.exchangeDelete
exchangeUnbindAwait | `suspend fun RabbitMQClient.exchangeUnbindAwait(destination: String, source: String, routingKey: String): Unit` `suspend fun RabbitMQClient.exchangeUnbindAwait(destination: String, source: String, routingKey: String, arguments: Map<String, Any>): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.exchangeUnbind
messageCountAwait | `suspend fun RabbitMQClient.messageCountAwait(queue: String): Long` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.messageCount
queueBindAwait | `suspend fun RabbitMQClient.queueBindAwait(queue: String, exchange: String, routingKey: String): Unit` `suspend fun RabbitMQClient.queueBindAwait(queue: String, exchange: String, routingKey: String, arguments: Map<String, Any>): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueBind
queueDeclareAutoAwait | `suspend fun RabbitMQClient.queueDeclareAutoAwait(): JsonObject` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueDeclareAuto
queueDeclareAwait | `suspend fun RabbitMQClient.queueDeclareAwait(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean): JsonObject` `suspend fun RabbitMQClient.queueDeclareAwait(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, config: JsonObject): JsonObject` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueDeclare
queueDeleteAwait | `suspend fun RabbitMQClient.queueDeleteAwait(queue: String): JsonObject` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueDelete
queueDeleteIfAwait | `suspend fun RabbitMQClient.queueDeleteIfAwait(queue: String, ifUnused: Boolean, ifEmpty: Boolean): JsonObject` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueDeleteIf
queueUnbindAwait | `suspend fun RabbitMQClient.queueUnbindAwait(queue: String, exchange: String, routingKey: String): Unit` `suspend fun RabbitMQClient.queueUnbindAwait(queue: String, exchange: String, routingKey: String, arguments: Map<String, Any>): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueUnbind
startAwait | `suspend fun RabbitMQClient.startAwait(): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.start
stopAwait | `suspend fun RabbitMQClient.stopAwait(): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.stop
waitForConfirmsAwait | `suspend fun RabbitMQClient.waitForConfirmsAwait(): Unit` `suspend fun RabbitMQClient.waitForConfirmsAwait(timeout: Long): Unit` Suspending version of method io.vertx.rabbitmq.RabbitMQClient.waitForConfirms