Fix #326

Close socket on timeout to prevent dangling connections.
amqp-node · Mar 20, 2017 · 68b9c42 · 68b9c42
1 parent 184b48e
commit 68b9c42
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/lib/connect.js b/lib/connect.js
@@ -176,8 +176,11 @@ function connect(url, socketOptions, openCallback) {
   }
 
   if (timeout) {
-    sock.setTimeout(
-      timeout, openCallback.bind(this, new Error('connect ETIMEDOUT')));
+    sock.setTimeout(timeout, function() {
+      sock.end();
+      sock.destroy();
+      openCallback(new Error('connect ETIMEDOUT'));
+    });
   }
 
   sock.once('error', function(err) {