0

我正在使用 RabbitMQ 队列,我在 node.js / express 应用程序中使用它,我正在使用 Wascally 作为我的库来消费和发布消息。

我的场景是,在消费者完成处理消息后,它再次将消息重新排队,因此任务是在一个循环中完成的。例如,消息启动从某个 API 下载数据的任务,完成后它再次发布相同的消息,因此将再次执行数据下载。

问题是,如果我的消费者应用程序崩溃,则消息将作为“未确认”保留在队列中。如果消费者在一段时间内(例如 30 秒)没有响应,我应该怎么做才能让我的消息返回队列?

4

0 回答 0