suspend fun AmqpClient.closeAwait(): Unit
Suspending version of method io.vertx.amqp.AmqpClient.close |
|
suspend fun AmqpClient.connectAwait(): AmqpConnection
Suspending version of method io.vertx.amqp.AmqpClient.connect |
|
suspend fun AmqpClient.createReceiverAwait(address: String): AmqpReceiver suspend fun AmqpClient.createReceiverAwait(address: String, messageHandler: (AmqpMessage) -> Unit): AmqpReceiver suspend fun AmqpClient.createReceiverAwait(address: String, receiverOptions: AmqpReceiverOptions, messageHandler: (AmqpMessage) -> Unit): AmqpReceiver
Suspending version of method io.vertx.amqp.AmqpClient.createReceiver |
|
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 |