Changed timing of messages on mongofw/wr replication.

riclolsen · May 25, 2024 · ff4ed93 · ff4ed93
1 parent ff27b43
commit ff4ed93
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/mongowr/customized_module.js b/src/mongowr/customized_module.js
@@ -103,11 +103,7 @@ async function procQueue() {
       //Log.log('Max: ' + maxSz)
       //Log.log('CntPrMx: ' + cntPrMx)
       Log.log('Queue Size: ' + msgQueue.size())
-      if (msgQueue.size() > 5000) {
-        msgQueue.clear()
-        Log.log('Queue too large! Emptied!')
-      }
-      // const dataObj = JSON.parse(msg)
+
       if (!dataObj?.cnt) {
         Log.log('Unexpected format')
       }
@@ -146,5 +142,10 @@ async function procQueue() {
     }
   }
 
+  if (msgQueue.size() > 5000) {
+    msgQueue.clear()
+    Log.log('Queue too large! Emptied!')
+  }
+
   setTimeout(procQueue, 100)
 }