servicebus - npm Package Compare versions

Comparing version 2.0.3 to 2.0.4

bus/rabbitmq/pubsubqueue.js

@@ -75,6 +75,11 @@ var events = require('events');
     if (self.listening) {
-      self.listenChannel.cancel(self.subscription.consumerTag, function () {
-        self.emit('unlistened');
-        cb();
-      });
+      // cancel misses callback version so we have to use the promise
+      self.listenChannel
+        .cancel(self.subscription.consumerTag)
+        .then(function () {
+          self.emit('unlistened');
+          if (cb) {
+            cb();
+          }
+        });
     } else {
@@ -81,0 +86,0 @@ self.on('listening', _unsubscribe.bind(this, cb));

package.json

@@ -10,3 +10,3 @@ {
   "description": "Simple service bus for sending events between processes using amqp.",
-  "version": "2.0.3",
+  "version": "2.0.4",
   "homepage": "https://github.com/mateodelnorte/servicebus",
@@ -13,0 +13,0 @@ "repository": {

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

56712

increased by1.85%

Number of package files

37

increased by2.78%

Lines of code

1345

increased by2.67%

No dependency changes