vertx / io.vertx.rxjava.rabbitmq / RabbitMQClient / rxBasicPublish

rxBasicPublish

open fun rxBasicPublish(exchange: String, routingKey: String, message: JsonObject): Single<Void>

Publish a message. Publishing to a non-existent exchange will result in a channel-level protocol exception, which closes the channel. Invocations of Channel#basicPublish will eventually block if a resource-driven alarm is in effect.

Parameters

exchange -

routingKey -

message -

Return