\r
package org.onap.holmes.common.config;\r
\r
+import lombok.Getter;\r
+import lombok.NoArgsConstructor;\r
+import lombok.Setter;\r
+\r
+@Getter\r
+@Setter\r
+@NoArgsConstructor\r
public class MQConfig {\r
\r
- public String brokerIp;\r
+ private String brokerIp;\r
\r
- public int brokerPort;\r
+ private int brokerPort;\r
\r
- public String brokerUsername;\r
+ private String brokerUsername;\r
\r
- public String brokerPassword;\r
+ private String brokerPassword;\r
}\r
@Inject
private AaiQuery aaiQuery;
- public static ConcurrentHashMap<String, String> loopControlNames = new ConcurrentHashMap<>();
- public static ConcurrentHashMap<String, String> alarmUniqueRequestID = new ConcurrentHashMap<>();
+ public static final ConcurrentHashMap<String, String> loopControlNames = new ConcurrentHashMap<>();
+ public static final ConcurrentHashMap<String, String> alarmUniqueRequestID = new ConcurrentHashMap<>();
public void publishPolicyMsg(PolicyMsg policyMsg, String dmaapConfigKey) {
try {
public void init() {\r
\r
String brokerURL =\r
- "tcp://" + mqConfigProvider.get().brokerIp + ":" + mqConfigProvider.get().brokerPort;\r
- connectionFactory = new ActiveMQConnectionFactory(mqConfigProvider.get().brokerUsername,\r
- mqConfigProvider.get().brokerPassword, brokerURL);\r
+ "tcp://" + mqConfigProvider.get().getBrokerIp() + ":" + mqConfigProvider.get().getBrokerPort();\r
+ connectionFactory = new ActiveMQConnectionFactory(mqConfigProvider.get().getBrokerUsername(),\r
+ mqConfigProvider.get().getBrokerPassword(), brokerURL);\r
}\r
\r
public void sendAlarmMQTopicMsg(VesAlarm alarm) {\r
@Test
public void init() {
MQConfig mqConfig = new MQConfig();
- mqConfig.brokerIp = "127.0.0.1";
- mqConfig.brokerPort = 61616;
- mqConfig.brokerPassword = "admin";
- mqConfig.brokerUsername = "admin";
+ mqConfig.setBrokerIp("127.0.0.1");
+ mqConfig.setBrokerPort(61616);
+ mqConfig.setBrokerPassword("admin");
+ mqConfig.setBrokerUsername("admin");
expect(mqConfigProvider.get()).andReturn(mqConfig).anyTimes();
PowerMock.replayAll();