suspend fun RabbitMQClient.basicAckAwait(deliveryTag: Long, multiple: Boolean): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicAck |
|
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 |
|
suspend fun RabbitMQClient.basicGetAwait(queue: String, autoAck: Boolean): RabbitMQMessage
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicGet |
|
suspend fun RabbitMQClient.basicNackAwait(deliveryTag: Long, multiple: Boolean, requeue: Boolean): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.basicNack |
|
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 |
|
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 |
|
suspend fun RabbitMQClient.confirmSelectAwait(): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.confirmSelect |
|
suspend fun RabbitMQClient.exchangeBindAwait(destination: String, source: String, routingKey: String): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.exchangeBind |
|
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 |
|
suspend fun RabbitMQClient.exchangeDeleteAwait(exchange: String): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.exchangeDelete |
|
suspend fun RabbitMQClient.exchangeUnbindAwait(destination: String, source: String, routingKey: String): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.exchangeUnbind |
|
suspend fun RabbitMQClient.messageCountAwait(queue: String): Long
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.messageCount |
|
suspend fun RabbitMQClient.queueBindAwait(queue: String, exchange: String, routingKey: String): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueBind |
|
suspend fun RabbitMQClient.queueDeclareAutoAwait(): JsonObject
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueDeclareAuto |
|
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 |
|
suspend fun RabbitMQClient.queueDeleteAwait(queue: String): DeleteOk
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueDelete |
|
suspend fun RabbitMQClient.queueDeleteIfAwait(queue: String, ifUnused: Boolean, ifEmpty: Boolean): DeleteOk
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.queueDeleteIf |
|
suspend fun RabbitMQClient.startAwait(): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.start |
|
suspend fun RabbitMQClient.stopAwait(): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.stop |
|
suspend fun RabbitMQClient.waitForConfirmsAwait(): Unit suspend fun RabbitMQClient.waitForConfirmsAwait(timeout: Long): Unit
Suspending version of method io.vertx.rabbitmq.RabbitMQClient.waitForConfirms |