From f4421abda87f9f98d5fd0de88b9e70b146eb91b2 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Fri, 31 Mar 2017 20:41:52 +0200
Subject: do the cheap ACK

---
 worker.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/worker.js b/worker.js
index 4c79f31..b9268f8 100644
--- a/worker.js
+++ b/worker.js
@@ -146,7 +146,7 @@ var RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost",
             // COMMIT
             await transaction.commit();
             console.log("acking batch");
-            await Promise.all(msgs.map(async (msg) => await ch.ack(msg) ));
+            await ch.ack(msgs.pop(), true);  // ack all messages until the last
             // request child jobs, notify player
             await Promise.all(matches.map(async (m) =>
                 await Promise.all(m.rosters.map(async (r) =>
-- 
cgit v1.3.1