activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1059638 - /activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/ActiveMQComponent.java
Date Sun, 16 Jan 2011 19:10:38 GMT
Author: tabish
Date: Sun Jan 16 19:10:38 2011
New Revision: 1059638

URL: http://svn.apache.org/viewvc?rev=1059638&view=rev
Log:
fix for: https://issues.apache.org/jira/browse/AMQ-3138

Modified:
    activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/ActiveMQComponent.java

Modified: activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/ActiveMQComponent.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/ActiveMQComponent.java?rev=1059638&r1=1059637&r2=1059638&view=diff
==============================================================================
--- activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/ActiveMQComponent.java
(original)
+++ activemq/trunk/activemq-camel/src/main/java/org/apache/activemq/camel/component/ActiveMQComponent.java
Sun Jan 16 19:10:38 2011
@@ -18,6 +18,7 @@ package org.apache.activemq.camel.compon
 
 import java.util.concurrent.CopyOnWriteArrayList;
 
+import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.Service;
 import org.apache.camel.CamelContext;
 import org.apache.camel.component.jms.JmsComponent;
@@ -59,6 +60,9 @@ public class ActiveMQComponent extends J
             ((ActiveMQConfiguration) answer.getConfiguration())
                     .setBrokerURL(brokerURL);
         }
+
+        // set the connection factory with the provided broker url
+        answer.setConnectionFactory(new ActiveMQConnectionFactory(brokerURL));
         return answer;
     }
 
@@ -73,7 +77,7 @@ public class ActiveMQComponent extends J
         super(configuration);
     }
 
-   
+
     public void setBrokerURL(String brokerURL) {
         if (getConfiguration() instanceof ActiveMQConfiguration) {
             ((ActiveMQConfiguration)getConfiguration()).setBrokerURL(brokerURL);



Mime
View raw message