fixes: destroy socket after idle timeout

amqp · May 5, 2020 · 7a69a74 · 7a69a74
1 parent 97f78d2
commit 7a69a74
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/connection.js b/lib/connection.js
@@ -345,6 +345,9 @@ Connection.prototype.abort_socket = function (socket) {
         this.socket.removeAllListeners('data');
         this.socket.removeAllListeners('error');
         this.socket.removeAllListeners('end');
+        if (typeof this.socket.destroy === 'function') {
+            this.socket.destroy();
+        }
         this._disconnected();
     }
 };