It's the current architecture; however, each `BQC` has to issue a consume on each queue; having it here allows each consumer to "recover" and consume if/when the queue becomes available, with each BQC tracking which queues it needs to consume from.