Optimized mongodb queries
Added a lock error when timing out
Splitting the payload generation + publish
Implementation of the redis publish, and rabbitmq confirm cleanup
recover_payloads_for_rabbitmq implementation
Added publisher recovery worker
The publisher worker nows expires locks every 10 seconds
Subscribers are now safe