stop trying to reconnect once connection has been closed by application

amqp · Dec 8, 2017 · 2f7cdba · 2f7cdba
1 parent 950c8fb
commit 2f7cdba
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/endpoint.js b/lib/endpoint.js
@@ -49,8 +49,10 @@ EndpointState.prototype.close = function () {
 };
 
 EndpointState.prototype.disconnected = function () {
+    var was_initialised = this.initialised;
     var was_open = this.local_open;
     this.init();
+    this.initialised = was_initialised;
     if (was_open) {
         this.open();
     } else {