Hopefully have the other producer/consumer setup now pipe messages through the correct queues.