Skip to content
Permalink
Browse files
Merged revision(s) 1375292 from activemq/activemq-dotnet/Apache.NMS.S…
…tomp/branches/1.5.x:

Reimplement fix for zombie consumers to update the failover state tracker.
Fixes https://issues.apache.org/jira/browse/AMQNET-394
  • Loading branch information
Jim Gomes committed Aug 20, 2012
1 parent d650366 commit fab06be2036df0c24157ee0e4e61f1843cd2e672
Showing 2 changed files with 2 additions and 4 deletions.
@@ -690,10 +690,7 @@ protected void DispatchMessage(MessageDispatch dispatch)
}
}

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)
@@ -450,6 +450,7 @@ public void Oneway(Command command)

if(command.IsRemoveInfo)
{
stateTracker.track(command);
// Simulate response to RemoveInfo command
Response response = new Response();
response.CorrelationId = command.CommandId;

0 comments on commit fab06be

Please sign in to comment.