worker:
- add domain error handling to amqp