From 78f4b0cc54f1a877f4e53f1a21b01f8c2791c9d1 Mon Sep 17 00:00:00 2001 From: schneefux Date: Tue, 4 Apr 2017 21:02:58 +0200 Subject: ack each message individually --- worker.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/worker.js b/worker.js index b65bb59..1772db6 100644 --- a/worker.js +++ b/worker.js @@ -250,12 +250,12 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI, // TODO: eliminate such cases earlier in the chain // and immediately NACK those broken matches, requeueing only the rest console.error(err); - await ch.nack(msgs.pop(), true, true); // nack all messages until the last and requeue + await Promise.all(msgs.map((m) => ch.nack(m, true)) ); // requeue return; // give up } console.log("acking batch"); - await ch.ack(msgs.pop(), true); // ack all messages until the last + await Promise.all(msgs.map((m) => ch.ack(m)) ); // notify compiler await Promise.all([ -- cgit v1.3.1