activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r825705 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/TransactionContext.cs
Date Thu, 15 Oct 2009 23:52:08 GMT
Author: tabish
Date: Thu Oct 15 23:52:07 2009
New Revision: 825705

URL: http://svn.apache.org/viewvc?rev=825705&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQNET-194

TransactionContext was sending commit and rollback commands as async which means no repsonse
from the broker.  This is bad for multiple reasons one of which is that the ConnectionStateTracker
wasn't removing the committed transaction data nor was it cleaning out the request map.

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=825705&r1=825704&r2=825705&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
Thu Oct 15 23:52:07 2009
@@ -80,7 +80,7 @@
                 info.Type = (int) TransactionType.Rollback;
                 info.ResponseRequired = false;
                 transactionId = null;
-                session.Connection.Oneway(info);
+                session.Connection.SyncRequest(info);
             }
             
             foreach (ISynchronization synchronization in synchronizations)
@@ -105,7 +105,7 @@
                 info.Type = (int) TransactionType.CommitOnePhase;
                 info.ResponseRequired = false;
                 transactionId = null;
-                session.Connection.Oneway(info);
+                session.Connection.SyncRequest(info);
             }
             
             foreach (ISynchronization synchronization in synchronizations)



Mime
View raw message