mirror of https://github.com/apache/activemq.git
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1059638 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
1b9e94fb46
commit
be9bdab07b
|
@ -18,6 +18,7 @@ package org.apache.activemq.camel.component;
|
|||
|
||||
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 JmsComponent {
|
|||
((ActiveMQConfiguration) answer.getConfiguration())
|
||||
.setBrokerURL(brokerURL);
|
||||
}
|
||||
|
||||
// set the connection factory with the provided broker url
|
||||
answer.setConnectionFactory(new ActiveMQConnectionFactory(brokerURL));
|
||||
return answer;
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue