FIX: Corrected the consume queue in mq.py