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

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

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

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

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