Recovery mechanism in place
Ack already processed messages when in recovery
Polling 0.2 on the main thread when exiting
Optimized the dependency lookup order
Recovery mechanism is more robust and instant