From 043b5746fd33dea805afeb71a5158a72d9743e1f Mon Sep 17 00:00:00 2001 From: schneefux Date: Thu, 27 Jul 2017 14:15:42 +0200 Subject: fix error handling msg syntax error --- worker.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'worker.js') 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); -- cgit v1.3.1