vertx / io.vertx.kotlin.amqp / io.vertx.amqp.AmqpClient

Extensions for io.vertx.amqp.AmqpClient

closeAwait

suspend fun AmqpClient.closeAwait(): Unit

Suspending version of method io.vertx.amqp.AmqpClient.close

connectAwait

suspend fun AmqpClient.connectAwait(): AmqpConnection

Suspending version of method io.vertx.amqp.AmqpClient.connect

createReceiverAwait

suspend fun AmqpClient.createReceiverAwait(address: String): AmqpReceiver
suspend fun AmqpClient.createReceiverAwait(address: String, receiverOptions: AmqpReceiverOptions): AmqpReceiver

Suspending version of method io.vertx.amqp.AmqpClient.createReceiver

createSenderAwait

suspend fun AmqpClient.createSenderAwait(address: String): AmqpSender
suspend fun AmqpClient.createSenderAwait(address: String, options: AmqpSenderOptions): AmqpSender

Suspending version of method io.vertx.amqp.AmqpClient.createSender