import org.glassfish.hk2.api.IterableProvider;\r
import org.jvnet.hk2.annotations.Service;\r
import org.onap.holmes.common.api.stat.Alarm;\r
+import org.onap.holmes.common.api.stat.VesAlarm;\r
import org.onap.holmes.common.constant.AlarmConst;\r
import org.onap.holmes.common.api.entity.CorrelationResult;\r
import org.onap.holmes.common.api.stat.AplusResult;\r
mqConfigProvider.get().brokerPassword, brokerURL);\r
}\r
\r
- public void sendAlarmMQTopicMsg(Alarm alarm) {\r
+ public void sendAlarmMQTopicMsg(VesAlarm alarm) {\r
sendMQTopicMsg(alarm);\r
}\r
\r
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);\r
if (t instanceof CorrelationResult) {\r
destination = session.createTopic(AlarmConst.MQ_TOPIC_NAME_ALARMS_CORRELATION);\r
- } else if (t instanceof Alarm) {\r
+ } else if (t instanceof VesAlarm) {\r
destination = session.createTopic(AlarmConst.MQ_TOPIC_NAME_ALARM);\r
}\r
messageProducer = session.createProducer(destination);\r
import org.junit.rules.ExpectedException;
import org.onap.holmes.common.api.stat.Alarm;
import org.onap.holmes.common.api.entity.CorrelationResult;
+import org.onap.holmes.common.api.stat.VesAlarm;
import org.onap.holmes.common.config.MQConfig;
import org.powermock.api.easymock.PowerMock;
import org.powermock.modules.junit4.rule.PowerMockRule;
@Test
public void sendAlarmMQTopicMsg() throws Exception {
- Alarm alarm = new Alarm();
+ VesAlarm alarm = new VesAlarm();
Connection connection = PowerMock.createMock(Connection.class);
Session session = PowerMock.createMock(Session.class);
Destination destination = PowerMock.createMock(Topic.class);
@Test
public void sendAlarmMQTopicMsg_exception() throws Exception {
thrown.expect(JMSException.class);
- Alarm alarm = new Alarm();
+ VesAlarm alarm = new VesAlarm();
expect(connectionFactory.createConnection()).andThrow(new JMSException(""));