summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--worker.js2
1 files changed, 1 insertions, 1 deletions
diff --git a/worker.js b/worker.js
index b9b6948..05d46dc 100644
--- a/worker.js
+++ b/worker.js
@@ -57,7 +57,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
persistent: true,
headers: msg.properties.headers
});
- await msg.nack(false, false);
+ await ch.nack(msg, false, false);
return;
}
await ch.ack(msg);