如何解决如何使用 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 举报，一经查实，本站将立刻删除。
