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

[ta...@apache.org]

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)