【发布时间】:2011-09-12 11:42:42
【问题描述】:
我正在通过 postwait 使用模块 node-amqp。
我可以发布/订阅一些消息到队列中,但我想手动确认这些消息。
例如,我希望读取消息而不是确认消息,然后对此消息执行一些计算,然后发送q.shift() 以确认消息并通过第二条消息。
我希望手动使用确认。
实际上我有一个允许使用标志{ack: false} 订阅的功能
然后我有一个手动创建q.shift() 的功能(如文档中所述)。
但是当我发布 2 条消息,然后我在没有确认的情况下阅读了 2 条消息时,我看到了 2 条消息。但我希望订阅者重复最初收到的相同消息,直到我没有确认为止。
我该如何使用这些方法?
【问题讨论】:
标签: javascript node.js rabbitmq amqp