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 <jgo...@apache.org> Authored: Fri Aug 17 23:19:09 2012 +0000 Committer: Jim Gomes <jgo...@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)