在RabbitMQ中获取当前未确认的消费者消息

问题描述 投票:0回答:1

我正在尝试正常关闭正在消耗RabbitMQ消息的进程。我知道我可以使用Channel.cancel来阻止RabbitMQ向该进程发送任何新消息,但是我也需要处理任何未决的,未确认的消息。我可以只打电话给Channel.nackAll并重新排队所有消息,但是如果我可以等到所有待处理的消息(已使用但尚未确认/未确认的消息)都已完成,那就更好了。

任何想法如何实现这一目标?

rabbitmq amqp sigterm
1个回答
0
投票
  • 取消消费者
  • 完成工作后,请确认您当前正在“工作”的消息
  • 完成上述操作后,关闭通道和连接。 RabbitMQ将所有未确认的内容重新加入队列。

NOTE: RabbitMQ团队监视rabbitmq-users mailing list,并且有时仅在StackOverflow上回答问题。

© www.soinside.com 2019 - 2024. All rights reserved.