1

我正在将 RabbitMQ 与 pika (Python) 一起使用，我想知道是否有办法确定消息被重新排队的次数？

一般的想法是，我希望我的工作人员能够告诉它正在处理的消息之前已被拒绝/重新排队 X 次，然后采取适当的措施来进行一些错误处理，然后明确地从如果达到 Y 次重试的限制，则队列。

我知道我可能会复制消息，增加优先级属性的值（甚至增加标头中的值），然后将副本发布到队列，然后确认原始消息（类似于方法我发现了这个例子），但我更愿意明确地取消并重新排队消息。

有任何想法吗？

4

0 回答 0