smqp - npm Package Compare versions

Comparing version 1.7.1 to 1.8.0

CHANGELOG.md

 Changelog
 =========
 
+# 1.8.0
+
+- Support turning off queue event listener - `queue.off(eventName, handler)`
+
 # 1.7.0
@@ -5,0 +9,0 @@

dist/src/Queue.js

@@ -46,2 +46,3 @@ "use strict";
     nackAll,
+    off,
     on,
@@ -334,2 +335,8 @@ peek,
 
+  function off(eventName, handler) {
+    if (!eventEmitter || !eventEmitter.off) return;
+    const pattern = `queue.${eventName}`;
+    return eventEmitter.off(pattern, handler);
+  }
+
   function purge() {
@@ -336,0 +343,0 @@ const toDelete = messages.filter(({

package.json

 {
   "name": "smqp",
-  "version": "1.7.1",
+  "version": "1.8.0",
   "description": "Synchronous message queuing package",
@@ -62,3 +62,3 @@ "author": {
     "chai": "^4.2.0",
-    "eslint": "^6.1.0",
+    "eslint": "^6.2.2",
     "markdown-toc": "^1.2.0",
@@ -65,0 +65,0 @@ "mocha": "^6.2.0",

src/Queue.js

@@ -34,2 +34,3 @@ import {generateId, sortByPriority} from './shared';
     nackAll,
+    off,
     on,
@@ -336,2 +337,8 @@ peek,
 
+  function off(eventName, handler) {
+    if (!eventEmitter || !eventEmitter.off) return;
+    const pattern = `queue.${eventName}`;
+    return eventEmitter.off(pattern, handler);
+  }
+
   function purge() {
@@ -338,0 +345,0 @@ const toDelete = messages.filter(({pending}) => !pending);

No alert changes

Improved metrics

Total package byte prevSize

74087

increased by0.64%

Lines of code

2280

increased by0.53%

No dependency changes