You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2017/03/06 23:29:58 UTC
[34/50] [abbrv] activemq-nms-stomp git commit: Remove zombie
consumers that were created after failover. Fixes
https://issues.apache.org/jira/browse/AMQNET-394
Remove zombie consumers that were created after failover. Fixes https://issues.apache.org/jira/browse/AMQNET-394
Project: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/commit/fd6ddc41
Tree: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/tree/fd6ddc41
Diff: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/diff/fd6ddc41
Branch: refs/heads/1.5.x
Commit: fd6ddc41bab706e30f822a9b4d603156dfe7c624
Parents: fa16a57
Author: Jim Gomes <jg...@apache.org>
Authored: Fri Aug 17 23:19:09 2012 +0000
Committer: Jim Gomes <jg...@apache.org>
Committed: Fri Aug 17 23:19:09 2012 +0000
----------------------------------------------------------------------
src/main/csharp/Connection.cs | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/blob/fd6ddc41/src/main/csharp/Connection.cs
----------------------------------------------------------------------
diff --git a/src/main/csharp/Connection.cs b/src/main/csharp/Connection.cs
index 4ca6aa5..ba3ccd3 100755
--- a/src/main/csharp/Connection.cs
+++ b/src/main/csharp/Connection.cs
@@ -683,6 +683,7 @@ namespace Apache.NMS.Stomp
}
Tracer.Error("No such consumer active: " + dispatch.ConsumerId);
+ transport.Oneway(new RemoveInfo() { ObjectId = dispatch.ConsumerId });
}
protected void OnTransportException(ITransport sender, Exception exception)