Add support to consume messages from multiple queues