Message queue consumer

Add a task to listen for messages on the published_documents exchange and update the corresponding entries.
Perhaps call payload "body" everywhere?