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
messageProducer.send(message);\r
session.commit();\r
} catch (Exception e) {\r
- log.error("Failed send correlation." + e.getMessage(), e);\r
+ log.error("Failed send correlation. " + e.getMessage(), e);\r
} finally {\r
if (connection != null) {\r
try {\r
connection.close();\r
} catch (JMSException e) {\r
- log.error("Failed close connection." + e.getMessage(), e);\r
+ log.error("Failed close connection. " + e.getMessage(), e);\r
}\r
}\r
}\r