amqp-connection-manager - npm Package Compare versions

Comparing version 1.3.0 to 1.3.1

lib/AmqpConnectionManager.js

@@ -62,7 +62,18 @@ // Generated by CoffeeScript 1.10.0
     AmqpConnectionManager.prototype.close = function() {
+      if (this._closed) {
+        return;
+      }
       this._closed = true;
-      this._channels.forEach(function(channel) {
+      return Promise.all(this._channels.map(function(channel) {
         return channel.close();
-      });
-      return this._channels = [];
+      }))["catch"](function() {}).then((function(_this) {
+        return function() {
+          var ref;
+          _this._channels = [];
+          if ((ref = _this._currentConnection) != null) {
+            ref.close();
+          }
+          return _this._currentConnection = null;
+        };
+      })(this));
     };
@@ -69,0 +80,0 @@

lib/ChannelWrapper.js

@@ -133,16 +133,19 @@ // Generated by CoffeeScript 1.10.0
     ChannelWrapper.prototype.close = function() {
-      var ref1;
-      this._working = false;
-      if (this._messages.length !== 0) {
-        this._messages.forEach(function(message) {
-          return message.reject(new Error('Channel closed'));
-        });
-      }
-      this._connectionManager.removeListener('connect', this._onConnect);
-      this._connectionManager.removeListener('disconnect', this._onDisconnect);
-      if ((ref1 = this._channel) != null) {
-        ref1.close();
-      }
-      this._channel = null;
-      return this.emit('close');
+      return Promise.resolve().then((function(_this) {
+        return function() {
+          var answer, ref1, ref2;
+          _this._working = false;
+          if (_this._messages.length !== 0) {
+            _this._messages.forEach(function(message) {
+              return message.reject(new Error('Channel closed'));
+            });
+          }
+          _this._connectionManager.removeListener('connect', _this._onConnect);
+          _this._connectionManager.removeListener('disconnect', _this._onDisconnect);
+          answer = (ref1 = (ref2 = _this._channel) != null ? ref2.close() : void 0) != null ? ref1 : Promise.resolve();
+          _this._channel = null;
+          _this.emit('close');
+          return answer;
+        };
+      })(this));
     };
@@ -149,0 +152,0 @@

package.json

 {
   "name": "amqp-connection-manager",
-  "version": "1.3.0",
+  "version": "1.3.1",
   "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

Improved metrics

Total package byte prevSize

26470

increased by2.21%

Lines of code

425

increased by3.41%

No dependency changes