Subscribe annotation now works
Added worker option with supervisord
A bit of refactoring and clean up