diff --git a/lib/connection.js b/lib/connection.js
index 02a22292..c6c7e86d 100644
--- a/lib/connection.js
+++ b/lib/connection.js
@@ -195,7 +195,6 @@ Connection.prototype.connect = function () {
 		this.socket.on("data", this.handleTransmissionError.bind(this));
 		this.socket.on("drain", this.socketDrained.bind(this));
 		this.socket.on("clientError", this.errorOccurred.bind(this));
-		this.socket.on("end", this.destroyConnection.bind(this));
 		this.socket.once("close", this.restartConnection.bind(this));
 
 		this.socket.socket.connect(this.options['port'], this.options['gateway']);