如何使用 Kombu 在rabbitmq 队列上设置单个活动消费者

问题描述

我有一个有 2 个消费者的队列。我希望消息按照消费者收到的顺序消费，但是，我的消息最终乱序，因为消费者正在并行处理它们（我相信使用循环法）。

我在 rabbitmq 的文档中遇到了 this，这让我相信有一种方法可以让我的消息按照收到的顺序被消费。我正在使用带有 kombu 的 python3.7。

我尝试了以下方法，但这对我不起作用，因为消息仍然无序使用。

from kombu import Queue as KombuQueue

KombuQueue(
            name="my_queue_name",exchange="my_exchange_name",routing_key=None,durable=True,exclusive=False,auto_delete=False,queue_arguments={"x-single-active-consumer": True}
)

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）