|
@@ -172,24 +172,16 @@ public class AlarmHandleServiceImpl implements AlarmHandleService {
|
|
|
Double.parseDouble(valuesArray.getString(i)));
|
|
|
}
|
|
|
triggerOrEndAlarm(dataTime, meterId, itemCode, paramMap);
|
|
|
- alarmRedisCache.releaseLock(entry.getKey());
|
|
|
- channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
} catch (Exception e) {
|
|
|
- try {
|
|
|
- channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
|
|
|
- } catch (IOException e1) {
|
|
|
- e1.printStackTrace();
|
|
|
- }
|
|
|
+ log.error("线程池处理发数信息发生错误",e);
|
|
|
}
|
|
|
}
|
|
|
+ alarmRedisCache.releaseLock(entry.getKey());
|
|
|
});
|
|
|
}
|
|
|
+ channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
|
|
|
} catch (Exception e) {
|
|
|
- try {
|
|
|
- channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
|
|
|
- } catch (IOException e1) {
|
|
|
- e1.printStackTrace();
|
|
|
- }
|
|
|
+ log.error("mq 接收处理发数发生错误",e);
|
|
|
}
|
|
|
|
|
|
}
|