amqp-connection-manager - npm Package Compare versions

Comparing version 1.3.2 to 1.3.3

lib/ChannelWrapper.js

@@ -105,9 +105,7 @@ // Generated by CoffeeScript 1.10.0
     ChannelWrapper.prototype.addSetup = pb["break"](function(setup) {
-      return Promise.resolve().then((function(_this) {
+      return (this._settingUp || Promise.resolve()).then((function(_this) {
         return function() {
           _this._setups.push(setup);
           if (_this._channel) {
-            return (_this._settingUp || Promise.resolve()).then(function() {
-              return setup(_this._channel);
-            });
+            return setup(_this._channel);
           }
@@ -120,9 +118,9 @@ };
       this._setups = _.without(this._setups, setup);
-      if (this._channel) {
-        return (this._settingUp || Promise.resolve()).then((function(_this) {
-          return function() {
+      return (this._settingUp || Promise.resolve()).then((function(_this) {
+        return function() {
+          if (_this._channel) {
             return pb.callFn(teardown, 1, null, _this._channel);
-          };
-        })(this));
-      }
+          }
+        };
+      })(this));
     });
@@ -129,0 +127,0 @@

package.json

 {
   "name": "amqp-connection-manager",
-  "version": "1.3.2",
+  "version": "1.3.3",
   "description": "Auto-reconnect and round robin support for amqplib.",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

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

Worsened metrics

Total package byte prevSize

26648

decreased by-0.27%

Lines of code

429

decreased by-0.46%

No dependency changes