diff options
| -rw-r--r-- | worker.js | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -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 }); |
