问题描述
pika.exceptions.ChannelClosed: (406, “PRECONDITION_FAILED - parameters for queue ‘test_persistent’ in vhost ‘/’ not equivalent”)
这个问题的描述是你的队列持久化的值不一致.
问题分析
这是因为生产者和消费者当中队列的durable的参数不一致,大多数情况是修改了其中的一个参数,忘记修改另一个参数了.
解决方案
将队列的声明语句改成这样: channel.queue_declare(queue=my_queue, durable=True)
注意:在生产者和消费者的代码中都要同时修改队列中durable的参数,durable=True.