diff --git a/lib/client.js b/lib/client.js
index 238b7f8f3..dcc138665 100644
--- a/lib/client.js
+++ b/lib/client.js
@@ -1856,6 +1856,7 @@ MqttClient.prototype._onConnect = function (packet) {
         that._invokeAllStoreProcessingQueue()
         that.emit('connect', packet)
       } else {
+        that.removeListener('close', remove)
         startStreamProcess()
       }
     })