Move amqp functionality into Amqp module