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 2009/11/06 15:01:20 UTC
svn commit: r833399 -
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs
Author: tabish
Date: Fri Nov 6 14:01:20 2009
New Revision: 833399
URL: http://svn.apache.org/viewvc?rev=833399&view=rev
Log:
* MessageConsumer.cs:
Add a check for closed to the exception notification logic in RollbackHelper
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs?rev=833399&r1=833398&r2=833399&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs Fri Nov 6 14:01:20 2009
@@ -912,7 +912,10 @@
}
catch(Exception e)
{
- this.session.Connection.OnSessionException(this.session, e);
+ if(!this.unconsumedMessages.Closed)
+ {
+ this.session.Connection.OnSessionException(this.session, e);
+ }
}
}