使用node-amqp模块的Node.js中的手动确认

Question

我正在通过postwait使用模块node-amqp。

我可以发布/订阅队列中的一些消息，但我希望手动确认这些消息。

例如，我希望读取消息而不进行确认，然后对该消息执行一些计算，然后发送q.shift()以确认该消息并遍历第二条消息。

我希望手动使用确认。

实际上，我有一个允许订阅标志为{ack: false}的函数，然后我有一个手动创建q.shift()的函数(正如文档中所说的)。

但是当我发布了2条消息，然后我读了2条消息，没有确认，我看到了2条消息。但我希望订阅者重复最初收到的相同消息，直到我不承认它。

如何使用这些方法？

Answer 1

我知道这个问题有点老了，只是我在找问题的时候才看到的。

您必须将"ack-flag“设置为true，以确保手动确认消息。ack: false表示确认将自动完成

queue.subscribe({ack: true}, ...