don't attempt to nack if ack fails

1 files changed, 3 insertions, 2 deletions

diff --git a/worker.js b/worker.js
index 6150cd1..77bbd0c 100644
--- a/worker.js
+++ b/worker.js
@@ -49,8 +49,6 @@ 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);
-            await ch.ack(msg);
         } catch (err) {
             // log, move to error queue and NACK on *any* error
             logger.error(err);
@@ -59,7 +57,10 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
                 headers: msg.properties.headers
             });
             await msg.nack(false, false);
+            return;
         }
+        logger.info("done", payload);
+        await ch.ack(msg);
     }, { noAck: false });
 
     // loop over API data objects