diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-09-24 20:43:40 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-09-24 20:43:40 +0200 |
| commit | 1111236479a9f72f8b65e1d30d7c13062251e368 (patch) | |
| tree | 3247b94a441cdb3a9433bae3ba2f2ccba8038b89 /worker.js | |
| parent | ededbe97ef64872258ee6d16be6576699f69274e (diff) | |
| download | processor-1111236479a9f72f8b65e1d30d7c13062251e368.tar.gz processor-1111236479a9f72f8b65e1d30d7c13062251e368.zip | |
attempt to fix service stuck with 'nothing to do'
Diffstat (limited to 'worker.js')
| -rw-r--r-- | worker.js | 9 |
1 files changed, 5 insertions, 4 deletions
@@ -244,15 +244,16 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { idle_timer = undefined; load_timer = undefined; - if (msgs.size == 0) { - logger.info("nothing to do"); - return; - } const player_objects = new Set(player_data), match_objects = new Set(match_data); player_data.clear(); match_data.clear(); + if (msgs.size == 0) { + logger.info("nothing to do"); + return; + } + try { await process(player_objects, match_objects); |
