X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=engine-d%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fholmes%2Fengine%2Fmqconsumer%2FMQConsumer.java;h=e77146fb95f1a64d6e3e351a898a18c2181d4688;hb=4ed7d0b1dd4dc81e66acdcd568b7212a28e3510f;hp=bd77312a7c2e94e32f65aa93c1efd8e799f79826;hpb=5b3f8b279725c337de6988e703cca418b3e53826;p=holmes%2Fengine-management.git

diff --git a/engine-d/src/main/java/org/onap/holmes/engine/mqconsumer/MQConsumer.java b/engine-d/src/main/java/org/onap/holmes/engine/mqconsumer/MQConsumer.java
index bd77312..e77146f 100644
--- a/engine-d/src/main/java/org/onap/holmes/engine/mqconsumer/MQConsumer.java
+++ b/engine-d/src/main/java/org/onap/holmes/engine/mqconsumer/MQConsumer.java
@@ -50,9 +50,9 @@ public class MQConsumer {
 
     public void registerAlarmTopicListener() {
         String brokerURL =
-                "tcp://" + mqConfigProvider.get().brokerIp + ":" + mqConfigProvider.get().brokerPort;
-        connectionFactory = new ActiveMQConnectionFactory(mqConfigProvider.get().brokerUsername,
-                mqConfigProvider.get().brokerPassword, brokerURL);
+                "tcp://" + mqConfigProvider.get().getBrokerIp() + ":" + mqConfigProvider.get().getBrokerPort();
+        connectionFactory = new ActiveMQConnectionFactory(mqConfigProvider.get().getBrokerUsername(),
+                mqConfigProvider.get().getBrokerPassword(), brokerURL);
 
         AlarmMqMessageListener listener = new AlarmMqMessageListener();
         listener.receive();