Serializable msgEntity = (Serializable) t;\r
Connection connection = null;\r
Session session;\r
- Destination destination;\r
+ Destination destination = null;\r
MessageProducer messageProducer;\r
\r
try {\r
connection = connectionFactory.createConnection();\r
connection.start();\r
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);\r
- destination = session.createTopic(AlarmConst.MQ_TOPIC_NAME_ALARMS_CORRELATION);\r
+ if (t instanceof CorrelationResult) {\r
+ destination = session.createTopic(AlarmConst.MQ_TOPIC_NAME_ALARMS_CORRELATION);\r
+ } else if (t instanceof Alarm) {\r
+ destination = session.createTopic(AlarmConst.MQ_TOPIC_NAME_ALARM);\r
+ }\r
messageProducer = session.createProducer(destination);\r
ObjectMessage message = session.createObjectMessage(msgEntity);\r
messageProducer.send(message);\r
package org.openo.holmes.common.api.stat;
+import java.util.Date;
import static org.hamcrest.core.IsEqual.equalTo;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertThat;
@Test
public void testToString() throws Exception {
- final Alarm alarmTemp = new Alarm();
- assertThat(alarmTemp.toString(), equalTo(alarm.toString()));
+ Alarm alarmTempA = new Alarm();
+ Alarm alarmTempB = new Alarm();
+ Date date = new Date();
+ alarmTempA.setClearedTime(date);
+ alarmTempA.setRaisedTime(date);
+ alarmTempA.setRaisedServerTime(date);
+ alarmTempB.setClearedTime(date);
+ alarmTempB.setRaisedTime(date);
+ alarmTempB.setRaisedServerTime(date);
+ assertThat(alarmTempA.toString(),equalTo(alarmTempB.toString()));
}
@Test