Added the fix suggested in postwait#300 to prevent econnreset.

dogeatdog · Jun 23, 2015 · 5489797 · 5489797 · seansullivan · Jan 6, 2017
1 parent f64704d
commit 5489797
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/lib/connection.js b/lib/connection.js
@@ -515,7 +515,8 @@ Connection.prototype._onMethod = function (channel, method, args) {
 
     case methods.connectionCloseOk:
       debug && debug("Received close-ok from server, closing socket");
-      this.socket.end();
+      //this.socket.end(); this causes the ECONNRESET error, as per https://github.com/postwait/node-amqp/issues/300
+      this.socket.destroy();
       break;
 
     case methods.connectionBlocked:

diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
-{ "name" : "amqp"
-, "description" : "AMQP driver for node"
+{ "name" : "dogeatdog-amqp"
+, "description" : "AMQP driver for node with a fix for econnreset"
 , "keywords" : [ "amqp" ]
-, "version" : "0.2.4"
+, "version" : "0.2.4.dogeatdog"
 , "author" : { "name" : "Ryan Dahl" }
 , "contributors" :
   [ { "name" : "Vasili Sviridov" }
@@ -19,13 +19,14 @@
   , { "name" : "David Barshow" }
   , { "name" : "Jason Pincin" }
   , { "name" : "Carl Hörberg" }
+  , { "name" : "Dennis Meerveld" }
   ]
 , "repository" :
   { "type" : "git"
-  , "url" : "git://github.com/postwait/node-amqp.git"
+  , "url" : "git://github.com/dogeatdog/node-amqp.git"
   }
 , "bugs" :
-  { "url" : "http://github.com/postwait/node-amqp/issues"
+  { "url" : "http://github.com/dogeatdog/node-amqp/issues"
   }
 , "main" : "./amqp"
 , "engines" : { "node" : "0.4 || 0.6 || 0.8 || 0.9 || 0.10 || 0.11 || 0.12" }