import org.openo.holmes.common.api.stat.AplusResult;\r
import org.openo.holmes.common.config.MQConfig;\r
import org.openo.holmes.common.constant.AlarmConst;\r
+import org.apache.activemq.ActiveMQConnectionFactory;\r
\r
@Service\r
@Slf4j\r
private IterableProvider<MQConfig> mqConfigProvider;\r
private ConnectionFactory connectionFactory;\r
\r
+ public MQProducer() {\r
+\r
+ }\r
+\r
+ 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
+ }\r
+\r
public void sendAlarmMQTopicMsg(Alarm alarm) {\r
sendMQTopicMsg(alarm);\r
}\r