From 9657f640e5dab17d6c2c6cd838a26c741768bebb Mon Sep 17 00:00:00 2001 From: schneefux Date: Tue, 25 Jul 2017 19:50:52 +0200 Subject: nvm the last 2 commits --- worker.js | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/worker.js b/worker.js index 7021209..e6790ab 100644 --- a/worker.js +++ b/worker.js @@ -221,10 +221,6 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { players: player_data.size, matches: match_data.size }); - if (msgs.size == 0) { - logger.info("nothing to do"); - return; - } // clean up to allow processor to accept while we wait for db clearTimeout(idle_timer); @@ -232,6 +228,10 @@ 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(); -- cgit v1.3.1