我正在尝试优雅地关闭一个正在消耗RabbitMQ消息的进程。我知道我可以使用Channel.cancel来阻止RabbitMQ向进程发送任何新消息,但我还需要处理任何挂起的、未确认的消息。我可以只调用Channel.nackAll并将它们重新排队,但如果我可以等到所有挂起的消息(已使用但尚未确认/否定的消息)都完成,那就更好了。有什么想法可以实现这一点吗?
Channel.cancel
Channel.nackAll
wpx232ag1#
1条答案
按热度按时间wpx232ag1#