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 2011/11/22 00:17:16 UTC
svn commit: r1204748 -
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/Connection.cs
Author: tabish
Date: Mon Nov 21 23:17:15 2011
New Revision: 1204748
URL: http://svn.apache.org/viewvc?rev=1204748&view=rev
Log:
fix for: https://issues.apache.org/jira/browse/AMQNET-352
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/Connection.cs
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/Connection.cs?rev=1204748&r1=1204747&r2=1204748&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/Connection.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/Connection.cs Mon Nov 21 23:17:15 2011
@@ -1014,8 +1014,12 @@ namespace Apache.NMS.ActiveMQ
{
Tracer.Debug("Connection: Transport has been Interrupted.");
- this.transportInterruptionProcessingComplete = new CountDownLatch(dispatchers.Count);
- if(Tracer.IsDebugEnabled)
+ // Ensure that if there's an advisory consumer we don't add it to the
+ // set of consumers that need interruption processing.
+ this.transportInterruptionProcessingComplete =
+ new CountDownLatch(dispatchers.Count - (this.advisoryConsumer != null ? 1 : 0));
+
+ if(Tracer.IsDebugEnabled)
{
Tracer.Debug("transport interrupted, dispatchers: " + dispatchers.Count);
}