diff --git a/lib/client.js b/lib/client.js
index cb8e69ef7..8f755cd92 100644
--- a/lib/client.js
+++ b/lib/client.js
@@ -410,7 +410,7 @@ MqttClient.prototype._clearReconnect = function() {
  */
 MqttClient.prototype._cleanUp = function() {
   this.conn.disconnect();
-  this.stream.end();
+  this.stream.destroy();
   if (this.pingTimer !== null) {
     clearInterval(this.pingTimer);
     this.pingTimer = null;
@@ -461,7 +461,6 @@ MqttClient.prototype._checkPing = function () {
     this.conn.pingreq();
   } else {
     this._cleanUp();
-    this.emit('close');
   }
 };