vertx / io.vertx.reactivex.rabbitmq / RabbitMQClient / rxBasicConsume

rxBasicConsume

open fun rxBasicConsume(queue: String, address: String): Completable

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): Completable

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

Parameters

queue -

address -

autoAck -

Return