open fun rxBasicConsume(queue: String, address: String): Completable
Start a non-nolocal, non-exclusive consumer, with auto acknowledgement and a server-generated consumerTag.
Return
open fun rxBasicConsume(queue: String, address: String, autoAck: Boolean): Completable
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
Return