activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1069828 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/QueueBrowser.cs
Date Fri, 11 Feb 2011 15:08:12 GMT
Author: tabish
Date: Fri Feb 11 15:08:12 2011
New Revision: 1069828

URL: http://svn.apache.org/viewvc?rev=1069828&view=rev
Log:
Allow for operation inside a transacted session.

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/QueueBrowser.cs

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/QueueBrowser.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/QueueBrowser.cs?rev=1069828&r1=1069827&r2=1069828&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/QueueBrowser.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.5.x/src/main/csharp/QueueBrowser.cs
Fri Feb 11 15:08:12 2011
@@ -127,6 +127,11 @@ namespace Apache.NMS.ActiveMQ
 
 			try
 			{
+            	if(session.IsTransacted && session.TransactionContext.InLocalTransaction)
+				{
+                	session.Commit();
+            	}
+				
 				consumer.Close();
 				consumer = null;
 			}



Mime
View raw message