vertx / io.vertx.rxjava.rabbitmq / RabbitMQClient / rxBasicConsume

rxBasicConsume

open fun rxBasicConsume(queue: String, address: String): Single<Void>

Start a non-nolocal, non-exclusive consumer, with auto acknowledgement and a server-generated consumerTag.

Parameters

queue -

address -

Return

open fun rxBasicConsume(queue: String, address: String, autoAck: Boolean): Single<Void>

Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.

Parameters

queue -

address -

autoAck -

Return