Skip to content
Permalink
Browse files
https://issues.apache.org/activemq/browse/AMQNET-264
Use new URISupport methods to preserve the options when non-destructive extraction is what we want.
  • Loading branch information
Timothy A. Bish committed Jul 20, 2010
1 parent c2bf133 commit 78f254fe767e68fe742b9a4f00db81532cce7846
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 3 deletions.
@@ -339,7 +339,8 @@ public ISession CreateSession(AcknowledgementMode sessionAcknowledgementMode)

// Set properties 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)
{
@@ -17,6 +17,7 @@

using System;
using System.Collections;
using System.Collections.Specialized;
using System.Threading;
using Apache.NMS.Stomp.Commands;
using Apache.NMS.Stomp.Util;
@@ -668,7 +669,8 @@ protected virtual ConsumerInfo CreateConsumerInfo(IDestination destination, stri
Destination amqDestination = destination as Destination;
if(amqDestination != null && amqDestination.Options != null)
{
URISupport.SetProperties(answer, amqDestination.Options, "consumer.");
StringDictionary options = URISupport.GetProperties(amqDestination.Options, "consumer.");
URISupport.SetProperties(answer, options);
}

return answer;
@@ -689,7 +691,8 @@ protected virtual ProducerInfo CreateProducerInfo(IDestination destination)
Destination amqDestination = destination as Destination;
if(amqDestination != null && amqDestination.Options != null)
{
URISupport.SetProperties(answer, amqDestination.Options, "producer.");
StringDictionary options = URISupport.GetProperties(amqDestination.Options, "producer.");
URISupport.SetProperties(answer, options);
}

return answer;

0 comments on commit 78f254f

Please sign in to comment.