fix(Link): properly call _detached on force detach to cleanup

noodlefrenzy · Nov 5, 2015 · 79544c4 · 79544c4
1 parent f9df0e8
commit 79544c4
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/lib/link.js b/lib/link.js
@@ -127,6 +127,7 @@ Link.prototype.detach = function() {
 Link.prototype.forceDetach = function() {
   debug('Force-detach for ' + this.name + '. Current state: ' + this.state());
   this.linkSM.forceDetach();
+  this._detached();
 };
 
 // private api
@@ -171,6 +172,7 @@ Link.prototype._sendDetach = function() {
 };
 
 Link.prototype._detached = function(frame) {
+  frame = frame || {};
   if (frame && frame.error) {
     this.emit(Link.ErrorReceived, frame.error);
   }

diff --git a/test/benchmarks/simple.js b/test/benchmarks/simple.js
@@ -20,7 +20,7 @@ client.connect('amqp://' + server)
       if (receivedCount === messageCount) {
         finish = new Date();
         console.log('=> sent ' + messageCount + ' messages in ' + (finish.getTime() - start.getTime()) + 'ms');
-        process.exit(0);
+        client.disconnect().then(function() { process.exit(0); });
       }
     });