abort early for empty batch

1 files changed, 4 insertions, 0 deletions

diff --git a/worker.js b/worker.js
index 9c2cc5e..7021209 100644
--- a/worker.js
+++ b/worker.js
@@ -221,6 +221,10 @@ 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);