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

Remove zombie consumers that were created after failover.  Fixes https://issues.apache.org/jira/browse/AMQNET-394
  • Loading branch information
Jim Gomes committed Aug 17, 2012
1 parent f887432 commit 51e5c019a75d42f35194d3a33693f2465ec1bfbf
Showing 1 changed file with 1 addition and 0 deletions.
@@ -691,6 +691,7 @@ protected void DispatchMessage(MessageDispatch dispatch)
}

Tracer.Error("No such consumer active: " + dispatch.ConsumerId);
transport.Oneway(new RemoveInfo() { ObjectId = dispatch.ConsumerId });
}

protected void OnTransportException(ITransport sender, Exception exception)

0 comments on commit 51e5c01

Please sign in to comment.