Improve logging and refactor AMQP processor