Replace amqp with amqplib. AMQP now works.