From 4eef07a8a6a056205fae9ba2890ce639e283575f Mon Sep 17 00:00:00 2001 From: Claus Ibsen Date: Tue, 24 Nov 2015 17:03:40 +0100 Subject: [PATCH] Fixes #5314 camel-amq - Should use the MQConnectionFactory by default --- .../main/java/io/fabric8/mq/camel/AMQConfiguration.java | 9 +++++++-- 1 file changed, 7 insertions(+), 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 index f72aa335ca1..e779a845b89 100644 --- 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