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

Extensions for io.vertx.rabbitmq.RabbitMQClient

basicAckAwait

suspend fun RabbitMQClient.basicAckAwait(deliveryTag: Long, multiple: Boolean): Unit

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): RabbitMQMessage

Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicGet

basicNackAwait

suspend fun RabbitMQClient.basicNackAwait(deliveryTag: Long, multiple: Boolean, requeue: Boolean): Unit

Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicNack

basicPublishAwait

suspend fun RabbitMQClient.basicPublishAwait(exchange: String, routingKey: String, body: Buffer): Unit
suspend fun RabbitMQClient.basicPublishAwait(exchange: String, routingKey: String, properties: BasicProperties, body: Buffer): 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): DeclareOk
suspend fun RabbitMQClient.queueDeclareAwait(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, config: JsonObject): DeclareOk

Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueDeclare

queueDeleteAwait

suspend fun RabbitMQClient.queueDeleteAwait(queue: String): DeleteOk

Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueDelete

queueDeleteIfAwait

suspend fun RabbitMQClient.queueDeleteIfAwait(queue: String, ifUnused: Boolean, ifEmpty: Boolean): DeleteOk

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