svn commit: r980025 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java

[gtully]

Author: gtully
Date: Wed Jul 28 11:44:53 2010
New Revision: 980025

URL: http://svn.apache.org/viewvc?rev=980025&view=rev
Log:
regression with https://issues.apache.org/activemq/browse/AMQ-2849 - 
FanoutTransportFactory needed to remove used parameters from original rather 
than from copy... resolve hang in FanoutTest

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java?rev=980025&r1=980024&r2=980025&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java
 Wed Jul 28 11:44:53 2010
@@ -62,7 +62,7 @@ public class FanoutTransportFactory exte
      */
     public Transport createTransport(URI location) throws IOException, 
URISyntaxException {
         CompositeData compositeData = URISupport.parseComposite(location);
-        Map<String, String> parameters = new HashMap<String, 
String>(compositeData.getParameters());
+        Map<String, String> parameters = compositeData.getParameters();
         FanoutTransport fanoutTransport = createTransport(parameters);        
         DiscoveryTransport discoveryTransport = 
DiscoveryTransportFactory.createTransport(fanoutTransport, compositeData);      
  
         return discoveryTransport;