diff options
| author |   Shiwei Tian <tian.shiwei@zte.com.cn> | 2017-09-12 15:37:43 +0800 |
|---|---|---|
| committer | Shiwei Tian <tian.shiwei@zte.com.cn> | 2017-09-12 16:30:44 +0800 |
| commit | bd773efb854a9a292bc6dd9e11bb00a4d4268b68 (patch) | |
| tree | adefe328c0a2722bbc9d5d9322885fd14ffc3208 /holmes-actions/src/main | |
| parent | f37f7595742b43c5bce7f4400184089ba1fb2d6c (diff) | |
modify MQproducer
Issue-ID: HOLMES-47
Change-Id: I9224601a0d29986d0a7a7ebaaac6e6846d22ac7e
Signed-off-by: Shiwei Tian <tian.shiwei@zte.com.cn>
Diffstat (limited to 'holmes-actions/src/main')
| -rw-r--r-- | holmes-actions/src/main/java/org/onap/holmes/common/producer/MQProducer.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/holmes-actions/src/main/java/org/onap/holmes/common/producer/MQProducer.java b/holmes-actions/src/main/java/org/onap/holmes/common/producer/MQProducer.java index 6aaa860..9483bb6 100644 --- a/holmes-actions/src/main/java/org/onap/holmes/common/producer/MQProducer.java +++ b/holmes-actions/src/main/java/org/onap/holmes/common/producer/MQProducer.java @@ -29,6 +29,7 @@ import lombok.extern.slf4j.Slf4j; import org.glassfish.hk2.api.IterableProvider;
import org.jvnet.hk2.annotations.Service;
import org.onap.holmes.common.api.stat.Alarm;
+import org.onap.holmes.common.api.stat.VesAlarm;
import org.onap.holmes.common.constant.AlarmConst;
import org.onap.holmes.common.api.entity.CorrelationResult;
import org.onap.holmes.common.api.stat.AplusResult;
@@ -52,7 +53,7 @@ public class MQProducer { mqConfigProvider.get().brokerPassword, brokerURL);
}
- public void sendAlarmMQTopicMsg(Alarm alarm) {
+ public void sendAlarmMQTopicMsg(VesAlarm alarm) {
sendMQTopicMsg(alarm);
}
@@ -75,7 +76,7 @@ public class MQProducer { session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
if (t instanceof CorrelationResult) {
destination = session.createTopic(AlarmConst.MQ_TOPIC_NAME_ALARMS_CORRELATION);
- } else if (t instanceof Alarm) {
+ } else if (t instanceof VesAlarm) {
destination = session.createTopic(AlarmConst.MQ_TOPIC_NAME_ALARM);
}
messageProducer = session.createProducer(destination);
|