Reimplement fix for zombie consumers to update the failover state tracker. 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/e106d93e Tree: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/tree/e106d93e Diff: http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/diff/e106d93e Branch: refs/heads/1.5.x Commit: e106d93ed962458a53146b40c55cf9a70e224ef2 Parents: a15a3fd Author: Jim Gomes <[email protected]> Authored: Mon Aug 20 22:53:27 2012 +0000 Committer: Jim Gomes <[email protected]> Committed: Mon Aug 20 22:53:27 2012 +0000 ---------------------------------------------------------------------- src/main/csharp/Connection.cs | 5 +---- src/main/csharp/Transport/Failover/FailoverTransport.cs | 1 + 2 files changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/blob/e106d93e/src/main/csharp/Connection.cs ---------------------------------------------------------------------- diff --git a/src/main/csharp/Connection.cs b/src/main/csharp/Connection.cs index 1ccb6de..283158d 100755 --- a/src/main/csharp/Connection.cs +++ b/src/main/csharp/Connection.cs @@ -682,10 +682,7 @@ namespace Apache.NMS.Stomp } } - Tracer.ErrorFormat("No such consumer active: {0}. Removing...", dispatch.ConsumerId); - RemoveInfo info = new RemoveInfo(); - info.ObjectId = dispatch.ConsumerId; - transport.Oneway(info); + Tracer.ErrorFormat("No such consumer active: {0}.", dispatch.ConsumerId); } protected void OnTransportException(ITransport sender, Exception exception) http://git-wip-us.apache.org/repos/asf/activemq-nms-stomp/blob/e106d93e/src/main/csharp/Transport/Failover/FailoverTransport.cs ---------------------------------------------------------------------- diff --git a/src/main/csharp/Transport/Failover/FailoverTransport.cs b/src/main/csharp/Transport/Failover/FailoverTransport.cs index 12c23af..b4ab1ff 100644 --- a/src/main/csharp/Transport/Failover/FailoverTransport.cs +++ b/src/main/csharp/Transport/Failover/FailoverTransport.cs @@ -450,6 +450,7 @@ namespace Apache.NMS.Stomp.Transport.Failover if(command.IsRemoveInfo) { + stateTracker.track(command); // Simulate response to RemoveInfo command Response response = new Response(); response.CorrelationId = command.CommandId;
