add error throw test case (unhandled exception inside task run)
emit the error as an event of the Worker
decouple the actual callback from the on "task" handler to avoid errors in the activity from killing the amqp connection