diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-25 19:42:12 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-07-25 19:42:12 +0200 |
| commit | 275977b7fd848f9574930dbd8584b4f26a911660 (patch) | |
| tree | 576769e20928d2011fb4c64869e3817d703d3ebd | |
| parent | 812baa8b75243175294186163b13ce25b3f852f8 (diff) | |
| download | processor-275977b7fd848f9574930dbd8584b4f26a911660.tar.gz processor-275977b7fd848f9574930dbd8584b4f26a911660.zip | |
don't abort unACKed on empty batch
| -rw-r--r-- | worker.js | 5 |
1 files changed, 0 insertions, 5 deletions
@@ -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(); |
