Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

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 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@980025 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2010-07-28 11:44:53 +00:00
parent 6b4509cdea
commit 4f32c6bcc1
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransportFactory.java
View File

@ -62,7 +62,7 @@ public class FanoutTransportFactory extends TransportFactory {
*/ */
public Transport createTransport(URI location) throws IOException, URISyntaxException { public Transport createTransport(URI location) throws IOException, URISyntaxException {
CompositeData compositeData = URISupport.parseComposite(location); 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); FanoutTransport fanoutTransport = createTransport(parameters);
DiscoveryTransport discoveryTransport = DiscoveryTransportFactory.createTransport(fanoutTransport, compositeData); DiscoveryTransport discoveryTransport = DiscoveryTransportFactory.createTransport(fanoutTransport, compositeData);
return discoveryTransport; return discoveryTransport;