activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jgo...@apache.org
Subject svn commit: r671638 - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp: Connection.cs Session.cs
Date Wed, 25 Jun 2008 18:58:19 GMT
Author: jgomes
Date: Wed Jun 25 11:58:19 2008
New Revision: 671638

URL: http://svn.apache.org/viewvc?rev=671638&view=rev
Log:
Start async delivery of messages for new sessions if the connection has already been started.
Stop async delivery of messages before removing session from connection when closing the session.

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

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs?rev=671638&r1=671637&r2=671638&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs Wed Jun
25 11:58:19 2008
@@ -160,6 +160,11 @@
 			System.Collections.Specialized.StringDictionary map = URISupport.ParseQuery(this.brokerUri.Query);
 			URISupport.SetProperties(session, map, "session.");
 
+			if(IsStarted)
+			{
+				session.StartAsyncDelivery(null);
+			}
+
 			sessions.Add(session);
 			return session;
 		}

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs?rev=671638&r1=671637&r2=671638&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs Wed Jun
25 11:58:19 2008
@@ -188,8 +188,8 @@
 
 				try
 				{
-					connection.RemoveSession(this);
 					StopAsyncDelivery();
+					connection.RemoveSession(this);
 					foreach(MessageConsumer consumer in GetConsumers())
 					{
 						consumer.Close();



Mime
View raw message