activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r833399 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs
Date Fri, 06 Nov 2009 14:01:20 GMT
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);
+				}
             }
         }
 



Mime
View raw message