activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r966023 - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp: Connection.cs MessageConsumer.cs Session.cs
Date Tue, 20 Jul 2010 21:42:43 GMT
Author: tabish
Date: Tue Jul 20 21:42:42 2010
New Revision: 966023

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

Use new URISupport methods to preserve the options when non-destructive extraction is what
we want.

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.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=966023&r1=966022&r2=966023&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 Tue Jul
20 21:42:42 2010
@@ -407,7 +407,8 @@ namespace Apache.NMS.ActiveMQ
 
             // Set propertieDs on session using parameters prefixed with "session."
 			StringDictionary options = URISupport.ParseQuery(this.brokerUri.Query);
-            URISupport.SetProperties(session, options, "session.");
+			options = URISupport.GetProperties(options, "session.");
+            URISupport.SetProperties(session, options);
 
             if(IsStarted)
             {

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs?rev=966023&r1=966022&r2=966023&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs
Tue Jul 20 21:42:42 2010
@@ -18,6 +18,7 @@ using System;
 using System.Threading;
 using System.Collections;
 using System.Collections.Generic;
+using System.Collections.Specialized;
 using Apache.NMS.ActiveMQ.Commands;
 using Apache.NMS;
 using Apache.NMS.Util;
@@ -96,8 +97,9 @@ namespace Apache.NMS.ActiveMQ
             // If the destination contained a URI query, then use it to set public properties
             // on the ConsumerInfo
             if(destination.Options != null)
-            {
-                URISupport.SetProperties(this.info, destination.Options, "consumer.");
+            {				
+				StringDictionary options = URISupport.GetProperties(destination.Options, "consumer.");
+				URISupport.SetProperties(this.info, options);
             }
 		}
 

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=966023&r1=966022&r2=966023&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 Tue Jul
20 21:42:42 2010
@@ -44,7 +44,7 @@ namespace Apache.NMS.ActiveMQ
         private bool dispatchAsync;
         private bool exclusive;
         private bool retroactive;
-        private byte priority = 4;
+        private byte priority = 0;
 
         private readonly SessionInfo info;
         private int consumerCounter;
@@ -421,7 +421,7 @@ namespace Apache.NMS.ActiveMQ
                 consumer = new MessageConsumer(this, GetNextConsumerId(), dest, null, selector,
prefetchSize,
                                                this.connection.PrefetchPolicy.MaximumPendingMessageLimit,
                                                noLocal, false, this.connection.DispatchAsync);
-
+				
                 this.AddConsumer(consumer);
                 this.Connection.SyncRequest(consumer.ConsumerInfo);
 



Mime
View raw message