Each device now consumes messages correctly from the data queues