Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化处理，避免重复异常消息入库

Browse Source
This commit is contained in:
hongawen
2023-08-18 15:19:14 +08:00
parent e4a9e4edf5
commit abd07dc172
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
iot-message/message-boot/src/main/java/com/njcn/message/consumer/AppAutoDataConsumer.java
View File

@@ -105,8 +105,11 @@ public class AppAutoDataConsumer extends EnhanceConsumerMessageHandler<AppAutoDa
exceptionMsg = exceptionMsg.substring(0,180); exceptionMsg = exceptionMsg.substring(0,180);
} }
rocketmqMsgErrorLog.setRecord(exceptionMsg); rocketmqMsgErrorLog.setRecord(exceptionMsg);
//单次消费异常 //如果是当前消息重试的则略过
rocketMqLogFeignClient.add(rocketmqMsgErrorLog); if(!message.getSource().startsWith(EnhanceMessageConstant.RETRY_PREFIX)){
//单次消费异常
rocketMqLogFeignClient.add(rocketmqMsgErrorLog);
}
} else { } else {
rocketmqMsgErrorLog.setRecord("重试消费" + super.getMaxRetryTimes() + "次，依旧消费失败。"); rocketmqMsgErrorLog.setRecord("重试消费" + super.getMaxRetryTimes() + "次，依旧消费失败。");
//重试N次后，依然消费异常 //重试N次后，依然消费异常