我正在尝试正常关闭正在消耗RabbitMQ消息的进程。我知道我可以使用Channel.cancel
来阻止RabbitMQ向该进程发送任何新消息,但是我也需要处理任何未决的,未确认的消息。我可以只打电话给Channel.nackAll
并重新排队所有消息,但是如果我可以等到所有待处理的消息(已使用但尚未确认/未确认的消息)都已完成,那就更好了。
任何想法如何实现这一目标?
NOTE: RabbitMQ团队监视rabbitmq-users
mailing list,并且有时仅在StackOverflow上回答问题。