vertx / io.vertx.reactivex.rabbitmq / RabbitMQClient / basicConsume

basicConsume

open fun basicConsume(queue: String, address: String, resultHandler: Handler<AsyncResult<Void>>): Unit

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

Parameters

queue -

address -

resultHandler -

open fun basicConsume(queue: String, address: String, autoAck: Boolean, resultHandler: Handler<AsyncResult<Void>>): Unit

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

Parameters

queue -

address -

autoAck -

resultHandler -

open fun basicConsume(queue: String, address: String, autoAck: Boolean, resultHandler: Handler<AsyncResult<Void>>, errorHandler: Handler<Throwable>): Unit

Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag and error handler

Parameters

queue -

address -

autoAck -

resultHandler -

errorHandler -