session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);\r
if (t instanceof CorrelationResult) {\r
destination = session.createTopic(AlarmConst.MQ_TOPIC_NAME_ALARMS_CORRELATION);\r
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);\r
if (t instanceof CorrelationResult) {\r
destination = session.createTopic(AlarmConst.MQ_TOPIC_NAME_ALARMS_CORRELATION);\r