vertx / io.vertx.kotlin.amqp / io.vertx.amqp.AmqpSender

Extensions for io.vertx.amqp.AmqpSender

closeAwait

suspend fun AmqpSender.closeAwait(): Unit

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

endAwait

suspend fun AmqpSender.endAwait(): Unit
suspend fun AmqpSender.endAwait(data: AmqpMessage): Unit

Suspending version of method io.vertx.amqp.AmqpSender.end

sendWithAckAwait

suspend fun AmqpSender.sendWithAckAwait(message: AmqpMessage): Unit

Suspending version of method io.vertx.amqp.AmqpSender.sendWithAck

writeAwait

suspend fun AmqpSender.writeAwait(data: AmqpMessage): Unit

Suspending version of method io.vertx.amqp.AmqpSender.write