summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-07-25 19:42:12 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-07-25 19:42:12 +0200
commit275977b7fd848f9574930dbd8584b4f26a911660 (patch)
tree576769e20928d2011fb4c64869e3817d703d3ebd
parent812baa8b75243175294186163b13ce25b3f852f8 (diff)
downloadprocessor-275977b7fd848f9574930dbd8584b4f26a911660.tar.gz
processor-275977b7fd848f9574930dbd8584b4f26a911660.zip
don't abort unACKed on empty batch
-rw-r--r--worker.js5
1 files changed, 0 insertions, 5 deletions
diff --git a/worker.js b/worker.js
index 37cc25a..9c2cc5e 100644
--- a/worker.js
+++ b/worker.js
@@ -228,11 +228,6 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
idle_timer = undefined;
load_timer = undefined;
- if (player_data.size + match_data.size == 0) {
- logger.info("buffers empty, nothing to do");
- return;
- }
-
const player_objects = new Set(player_data),
match_objects = new Set(match_data);
player_data.clear();