Added better logging via Monolog. Also made some changes so that on some instances the worker could continue working if broker is restarted.