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