From 4ed7d0b1dd4dc81e66acdcd568b7212a28e3510f Mon Sep 17 00:00:00 2001 From: GuangrongFu Date: Thu, 8 Mar 2018 17:15:53 +0800 Subject: Fixed Some Sonar Findings Change-Id: I7edd761e5ce9026dd8a09da2e2bcabbb2dc255b5 Issue-ID: HOLMES-118 Signed-off-by: GuangrongFu --- .../src/main/java/org/onap/holmes/engine/mqconsumer/MQConsumer.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'engine-d/src/main/java/org') 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(); -- cgit 1.2.3-korg