fix error handling msg syntax errorrelease/2.14.0

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);