keuss - npm Package Compare versions

Comparing version 1.4.3 to 1.4.4

backends/mongo.js

@@ -9,4 +9,4 @@ 'use strict';
 
-var Queue = require ('../Queue');
-var QFactory =   require ('../QFactory');
+var Queue =    require ('../Queue');
+var QFactory = require ('../QFactory');
 
@@ -241,10 +241,10 @@ class SimpleMongoQueue extends Queue {
   close (cb) {
-    if (this._mongo_conn) {
-      this._mongo_conn.close ();
-      this._mongo_conn = null;
-    } 
+    super.close (() => {
+      if (this._mongo_conn) {
+        this._mongo_conn.close ();
+        this._mongo_conn = null;
+      } 
     
-    if (cb) {
-      return cb ();
-    }
+      if (cb) return cb ();
+    });
   }
@@ -251,0 +251,0 @@

backends/pl-mongo.js

@@ -315,10 +315,10 @@ 'use strict';
   close (cb) {
-    if (this._mongo_conn) {
-      this._mongo_conn.close ();
-      this._mongo_conn = null;
-    } 
+    super.close (() => {
+      if (this._mongo_conn) {
+        this._mongo_conn.close ();
+        this._mongo_conn = null;
+      } 
     
-    if (cb) {
-      return cb ();
-    }
+      if (cb) return cb ();
+    });
   }
@@ -325,0 +325,0 @@

backends/ps-mongo.js

@@ -274,10 +274,10 @@ 'use strict';
   close (cb) {
-    if (this._mongo_conn) {
-      this._mongo_conn.close ();
-      this._mongo_conn = null;
-    } 
+    super.close (() => {
+      if (this._mongo_conn) {
+        this._mongo_conn.close ();
+        this._mongo_conn = null;
+      } 
     
-    if (cb) {
-      return cb ();
-    }
+      if (cb) return cb ();
+    });
   }
@@ -284,0 +284,0 @@

backends/redis-list.js

@@ -116,7 +116,6 @@ 'use strict';
   close (cb) {
-    if (this._rediscl) this._rediscl.quit();
-    
-    if (cb) {
-      return cb ();
-    }
+    super.close (() => {
+      if (this._rediscl) this._rediscl.quit();
+      if (cb) return cb ();
+    });
   }
@@ -123,0 +122,0 @@

backends/redis-oq.js

@@ -178,7 +178,6 @@ 'use strict';
   close (cb) {
-    if (this._rediscl) this._rediscl.quit();
-    
-    if (cb) {
-      return cb ();
-    }
+    super.close (() => {
+      if (this._rediscl) this._rediscl.quit();
+      if (cb) return cb ();
+    });
   }
@@ -185,0 +184,0 @@

package.json

 {
   "name": "keuss",
-  "version": "1.4.3",
+  "version": "1.4.4",
   "keywords": [
@@ -5,0 +5,0 @@ "queue",

QFactory.js

@@ -53,3 +53,5 @@ 'use strict';
   close (cb) {
-    cb();
+    this._stats_factory.close ();
+    this._signaller_factory.close (); 
+    cb ();
   }
@@ -56,0 +58,0 @@

README.md

@@ -302,2 +302,4 @@ # keuss
 
+If no tr is passed, or it is null, all pending pop operations on the queue are cancelled
+
 #### Commit a reserved element
@@ -304,0 +306,0 @@ ```javascript

signal/local.js

@@ -41,2 +41,5 @@ 'use strict';
     return new LocalSignal (queue, this, opts);
+  } 
+
+  close () {
   }
@@ -43,0 +46,0 @@ }

signal/mongo-capped.js

@@ -57,2 +57,6 @@ 'use strict';
   }
+
+  close () {
+    this._mubsub.close ();
+  }
 }
@@ -59,0 +63,0 @@

signal/redis-pubsub.js

@@ -61,2 +61,6 @@ 'use strict';
   }
+
+  close () {
+    this._rediscl.quit();
+  }
 }
@@ -63,0 +67,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

199079

increased by0.2%

Lines of code

4612

increased by0.22%

Number of lines in readme file

387

increased by0.52%

No dependency changes