support for consuming multiple queues