activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nmitt...@apache.org
Subject svn commit: r396325 - in /incubator/activemq/trunk/cms/activemqcms/src/activemq: ActiveMQConnectionFactory.cpp transport/stomp/StompTransportFactory.cpp
Date Sun, 23 Apr 2006 21:52:56 GMT
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, "", "" );
 }
 



Mime
View raw message