svn commit: r833399 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs

View: New views
1 Messages — Rating Filter:   Alert me  

svn commit: r833399 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs

by tabish :: Rate this Message:

Reply to Author | View Threaded | Show Only this Message

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);
+ }
             }
         }