fix(link): emit detached event when force detached locally

noodlefrenzy · Aug 18, 2016 · d2531ba · d2531ba
1 parent aa65f79
commit d2531ba
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 1 deletion.
diff --git a/lib/link.js b/lib/link.js
@@ -8,7 +8,8 @@ var EventEmitter = require('events').EventEmitter,
 
     debug = require('debug')('amqp10:link'),
     u = require('./utilities'),
-    frames = require('./frames');
+    frames = require('./frames'),
+    errors = require('./errors');
 
 function Link(session, handle, linkPolicy) {
   this.policy = linkPolicy;
@@ -140,6 +141,10 @@ Link.prototype.forceDetach = function() {
   debug('force detach for ' + this.name + '. current state: ' + state);
   if (!!this._reattachTimer) clearTimeout(this._reattachTimer);
   this.linkSM.forceDetach();
+  this.emit(Link.Detached, {
+    closed: true,
+    error: new errors.ProtocolError('amqp:link:detach-forced', 'detach-forced')
+  });
 };
 
 // private api

diff --git a/test/integration/qpid/client.test.js b/test/integration/qpid/client.test.js
@@ -237,5 +237,14 @@ describe('Client', function() {
       });
   });
 
+  it('should emit a detached event when link is force detached locally', function(done) {
+    test.client.connect(config.address)
+      .then(function() { return test.client.createReceiver(config.defaultLink); })
+      .then(function(link) {
+        link.on('detached', function() { done(); });
+        return test.client.disconnect();
+      });
+  });
+
 });
 });