Author: tabish
Date: Fri Jan 9 11:35:14 2009
New Revision: 733130
URL: http://svn.apache.org/viewvc?rev=733130&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQCPP-100
Some initial refactoring work that leads to V3 and addition of Failover.
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnectionFactory.cpp
Modified:
activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnectionFactory.cpp
URL:
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnectionFactory.cpp?rev=733130&r1=733129&r2=733130&view=diff
==============================================================================
---
activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnectionFactory.cpp
(original)
+++
activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnectionFactory.cpp
Fri Jan 9 11:35:14 2009
@@ -117,9 +117,6 @@
// Try to convert the String URL into a valid URI
URI uri( url );
- // Parse out properties so they can be passed to the Connectors.
- activemq::util::URISupport::parseQuery( uri.getQuery(),
properties.get() );
-
// Store login data in the properties
properties->setProperty(
ActiveMQConstants::toString(
@@ -131,6 +128,9 @@
ActiveMQConstants::toString(
ActiveMQConstants::PARAM_CLIENTID ), clientIdLocal );
+ // Parse out properties so they can be passed to the Connectors.
+ activemq::util::URISupport::parseQuery( uri.getQuery(),
properties.get() );
+
// Use the TransportBuilder to get our Transport
transport.reset(
TransportRegistry::getInstance().findFactory( uri.getScheme()
)->create( url ) );
