diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-10-01 10:31:09 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-10-01 10:31:09 +0200 |
| commit | cd72d251a6242a4f8018d1eb725c16ca120c375f (patch) | |
| tree | 2a2264a024b60a496dfe5dad9bf15317a66a30a9 | |
| parent | d6d291343269287f51c52baa42ff58ae9bca1e46 (diff) | |
| download | cruncher-cd72d251a6242a4f8018d1eb725c16ca120c375f.tar.gz cruncher-cd72d251a6242a4f8018d1eb725c16ca120c375f.zip | |
fix typo making debug NACK fail, add forgotten return
| -rw-r--r-- | worker.js | 3 |
1 files changed, 2 insertions, 1 deletions
@@ -126,7 +126,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()); |
