Message queue consumer

Add a task to listen for messages on the published_documents exchange and update the corresponding entries.