migrate amqp code from pushmq