【问题标题】:Manual acknowledgments in Node.js using node-amqp module使用 node-amqp 模块在 Node.js 中手动确认
【发布时间】:2011-09-12 11:42:42
【问题描述】:

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

我可以发布/订阅一些消息到队列中,但我想手动确认这些消息。

例如,我希望读取消息而不是确认消息,然后对此消息执行一些计算,然后发送q.shift() 以确认消息并通过第二条消息。

我希望手动使用确认。

实际上我有一个允许使用标志{ack: false} 订阅的功能 然后我有一个手动创建q.shift() 的功能(如文档中所述)。

但是当我发布 2 条消息,然后我在没有确认的情况下阅读了 2 条消息时,我看到了 2 条消息。但我希望订阅者重复最初收到的相同消息,直到我没有确认为止。

我该如何使用这些方法?

【问题讨论】:

    标签: javascript node.js rabbitmq amqp


    【解决方案1】:

    我知道这个问题有点老了,我在搜索问题时才看到它

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

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

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2016-02-28
      • 2012-11-21
      • 2011-12-14
      • 2011-08-12
      • 1970-01-01
      相关资源
      最近更新 更多