summaryrefslogtreecommitdiff
path: root/worker.js
diff options
context:
space:
mode:
Diffstat (limited to 'worker.js')
-rw-r--r--worker.js9
1 files changed, 5 insertions, 4 deletions
diff --git a/worker.js b/worker.js
index 0adf09a..d3292ba 100644
--- a/worker.js
+++ b/worker.js
@@ -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);