activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1058331 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs
Date Wed, 12 Jan 2011 21:52:45 GMT
Author: tabish
Date: Wed Jan 12 21:52:45 2011
New Revision: 1058331

URL: http://svn.apache.org/viewvc?rev=1058331&view=rev
Log:
https://issues.apache.org/jira/browse/AMQNET-290

Since the IEnlistmentNotification events are called from another thread and the exception
is not propagated back to the client in any way, instead pass the exception on to connection
via the OnSessionException method.

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs?rev=1058331&r1=1058330&r2=1058331&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs
Wed Jan 12 21:52:45 2011
@@ -323,7 +323,7 @@ namespace Apache.NMS.ActiveMQ
                 Tracer.Debug("Transaction Commit failed with error: " + ex.Message);
                 AfterRollback();
                 enlistment.Done();
-                throw;
+                this.session.Connection.OnSessionException(this.session, ex);
             }
             finally
             {
@@ -364,7 +364,7 @@ namespace Apache.NMS.ActiveMQ
                 Tracer.Debug("Transaction Single Phase Commit failed with error: " + ex.Message);
                 AfterRollback();
                 enlistment.Done();
-                throw;
+                this.session.Connection.OnSessionException(this.session, ex);
             }
             finally
             {
@@ -406,7 +406,7 @@ namespace Apache.NMS.ActiveMQ
                 Tracer.Debug("Transaction Rollback failed with error: " + ex.Message);
                 AfterRollback();
                 enlistment.Done();
-                throw;
+                this.session.Connection.OnSessionException(this.session, ex);
             }
             finally
             {



Mime
View raw message