summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-10-01 10:31:09 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-10-01 10:31:21 +0200
commit08b3dba6adfba35c4dca75538b04543286a836ee (patch)
tree9214eb43eb7c2af1cad641ba179abecf076bd58c
parent163a93189c219e439e142eee3e964e1fba7ddbc0 (diff)
downloadcruncher-08b3dba6adfba35c4dca75538b04543286a836ee.tar.gz
cruncher-08b3dba6adfba35c4dca75538b04543286a836ee.zip
fix typo making debug NACK fail, add forgotten returnrelease/2.17.0
-rw-r--r--worker.js3
1 files changed, 2 insertions, 1 deletions
diff --git a/worker.js b/worker.js
index be82f81..0075944 100644
--- a/worker.js
+++ b/worker.js
@@ -86,7 +86,8 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
// and forget a `id.toString()`, creating huge blobs of zeros,
// which makes Sequelize panic because the packets are 2MB.
// May god forgive me for deploying debug code…
- await ch.nack(m, false, false);
+ await ch.nack(msg, false, false);
+ return;
}
participants.add(msg.content.toString());