vertx / io.vertx.kotlin.amqp / io.vertx.amqp.AmqpConnection

Extensions for io.vertx.amqp.AmqpConnection

closeAwait

suspend fun AmqpConnection.closeAwait(): Unit

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

createAnonymousSenderAwait

suspend fun AmqpConnection.createAnonymousSenderAwait(): AmqpSender

Suspending version of method io.vertx.amqp.AmqpConnection.createAnonymousSender

createDynamicReceiverAwait

suspend fun AmqpConnection.createDynamicReceiverAwait(): AmqpReceiver

Suspending version of method io.vertx.amqp.AmqpConnection.createDynamicReceiver

createReceiverAwait

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

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

createSenderAwait

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

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