Changed timing of messages on mongofw/wr replication.

riclolsen · May 25, 2024 · ff27b43 · ff27b43
1 parent a66fca9
commit ff27b43
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/src/mongowr/customized_module.js b/src/mongowr/customized_module.js
@@ -103,7 +103,10 @@ 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')
@@ -134,10 +137,9 @@ async function procQueue() {
           )
 
       await collection.updateOne(
-        {
-          ...dataObj.documentKey,
-        },
-        { $set: { ...dataObj.updateDescription.updatedFields } }
+        { ...dataObj.documentKey },
+        { $set: { ...dataObj.updateDescription.updatedFields } },
+        { writeConcern: { w: 0 } }
       )
     } catch (e) {
       Log.log('Error: ' + e)