From 1407f019e8f665f9812fd5525f991791aa741581 Mon Sep 17 00:00:00 2001 From: schneefux Date: Wed, 26 Jul 2017 20:39:37 +0200 Subject: move debug code, fixes reference error --- worker.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/worker.js b/worker.js index 77bbd0c..b9b6948 100644 --- a/worker.js +++ b/worker.js @@ -49,6 +49,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { let payload = JSON.parse(msg.content.toString()), notify = msg.properties.headers.notify; // where to send progress report await getAPI(payload, notify); + logger.info("done", payload); } catch (err) { // log, move to error queue and NACK on *any* error logger.error(err); @@ -59,7 +60,6 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { await msg.nack(false, false); return; } - logger.info("done", payload); await ch.ack(msg); }, { noAck: false }); -- cgit v1.3.1