svn commit: r396325 - in /incubator/activemq/trunk/cms/activemqcms/src/activemq: ActiveMQConnectionFactory.cpp transport/stomp/StompTransportFactory.cpp

[nmittler]

Author: nmittler
Date: Sun Apr 23 14:52:54 2006
New Revision: 396325

URL: http://svn.apache.org/viewcvs?rev=396325&view=rev
Log:
Fixed broker url for Jira issue AMQ-686

Modified:
    
incubator/activemq/trunk/cms/activemqcms/src/activemq/ActiveMQConnectionFactory.cpp
    
incubator/activemq/trunk/cms/activemqcms/src/activemq/transport/stomp/StompTransportFactory.cpp

Modified: 
incubator/activemq/trunk/cms/activemqcms/src/activemq/ActiveMQConnectionFactory.cpp
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/cms/activemqcms/src/activemq/ActiveMQConnectionFactory.cpp?rev=396325&r1=396324&r2=396325&view=diff
==============================================================================
--- 
incubator/activemq/trunk/cms/activemqcms/src/activemq/ActiveMQConnectionFactory.cpp
 (original)
+++ 
incubator/activemq/trunk/cms/activemqcms/src/activemq/ActiveMQConnectionFactory.cpp
 Sun Apr 23 14:52:54 2006
@@ -48,7 +48,7 @@
        this->userName = userName;
        this->password = password;
 
-    brokerUrl = brokerUrl;
+    this->brokerUrl = brokerUrl;
     
     transportFactory = new activemq::transport::stomp::StompTransportFactory();
 }

Modified: 
incubator/activemq/trunk/cms/activemqcms/src/activemq/transport/stomp/StompTransportFactory.cpp
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/cms/activemqcms/src/activemq/transport/stomp/StompTransportFactory.cpp?rev=396325&r1=396324&r2=396325&view=diff
==============================================================================
--- 
incubator/activemq/trunk/cms/activemqcms/src/activemq/transport/stomp/StompTransportFactory.cpp
 (original)
+++ 
incubator/activemq/trunk/cms/activemqcms/src/activemq/transport/stomp/StompTransportFactory.cpp
 Sun Apr 23 14:52:54 2006
@@ -26,8 +26,16 @@
 
////////////////////////////////////////////////////////////////////////////////
 Transport* StompTransportFactory::createTransport( const char* brokerUrl ){
     
-    brokerHost = "127.0.0.1";
-    brokerPort = 61626;
+    string temp = brokerUrl;
+    unsigned int ix = temp.find( ':' );
+    if( ix == string::npos ){
+        throw new ActiveMQException( "StompTransportFactory::createTransport - 
no port provided in url" );
+    }
+    
+    brokerHost = temp.substr(0,ix);
+    
+    sscanf(brokerUrl+ix+1, "%d", &brokerPort );
+    
     return new StompTransport( brokerHost.c_str(), brokerPort, "", "" );
 }