diff --git a/src/AmqpConnectionManager.js b/src/AmqpConnectionManager.js
index b91af0e4..0a8d9255 100644
--- a/src/AmqpConnectionManager.js
+++ b/src/AmqpConnectionManager.js
@@ -89,6 +89,7 @@ export default class AmqpConnectionManager extends EventEmitter {
             .then(() => {
                 this._channels = [];
                 if(this._currentConnection) {
+                    this._currentConnection.removeAllListeners('close');
                     this._currentConnection.close();
                 }
                 this._currentConnection = null;