Introduced a MessageQueueManager. It should keep a registry of queues and manage publishing to them the polling of them.