Fixes #5314 camel-amq - Should use the MQConnectionFactory by default

fabric8io · Nov 24, 2015 · 4eef07a · 4eef07a
1 parent 8d3fdb9
commit 4eef07a
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/components/mq/camel-amq/src/main/java/io/fabric8/mq/camel/AMQConfiguration.java b/components/mq/camel-amq/src/main/java/io/fabric8/mq/camel/AMQConfiguration.java
@@ -15,9 +15,8 @@
  */
 package io.fabric8.mq.camel;
 
+import io.fabric8.mq.core.MQConnectionFactory;
 import io.fabric8.mq.core.MQs;
-import io.fabric8.utils.Strings;
-import io.fabric8.utils.Systems;
 import org.apache.activemq.camel.component.ActiveMQConfiguration;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -33,10 +32,16 @@ public class AMQConfiguration extends ActiveMQConfiguration {
     private String failoverUrlParameters;
 
     public AMQConfiguration() {
+        // use MQConnectionFactory as the out of the box connection factory
+        // as it can lookup the ActiveMQ broker using kubernetes services and the ENV variables
+        setConnectionFactory(new MQConnectionFactory());
     }
 
     public AMQConfiguration(AMQComponent component) {
         super.setActiveMQComponent(component);
+        // use MQConnectionFactory as the out of the box connection factory
+        // as it can lookup the ActiveMQ broker using kubernetes services and the ENV variables
+        setConnectionFactory(new MQConnectionFactory());
     }
 
     @Override