【问题标题】:Delete exclusive crashed queue in RabbitMQ删除 RabbitMQ 中的独占崩溃队列
【发布时间】:2018-07-24 06:36:46
【问题描述】:

有一个排他队列。应用程序失败并且没有正确关闭连接。

当应用重新启动时,它会尝试声明新的队列,但已经存在。我尝试从 web admin 和 rabbitadmin 中删除这些,但它不起作用。

是否可以在不删除虚拟主机的情况下删除独占崩溃队列?

【问题讨论】:

    标签: rabbitmq


    【解决方案1】:

    是的,你可以试试这个:

       rabbitmqctl eval '{ok, Q} = rabbit_amqqueue:lookup(rabbit_misc:r(<<"/">>, queue, <<"springCloudHystrixStream.anonymous.rq_ghYeMR7mbYJ8PzMyF8Q">>)), rabbit_amqqueue:delete_crashed(Q).'
    

    / 是您的虚拟主机,springCloudHystrixStream.anonymous.rq_ghYeMR7mbYJ8PzMyF8Q 是您专属的崩溃队列。

    【讨论】: