wangli/tyr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:(feature/REQ-3342) 解决广播模式下消费消息异常进入延迟队列的问题，现在的场景如果消费失败，再次重试也是失败，所以后续有本地做重试后切换到本地重试，失败进行告警，做手动触发

Browse Source
This commit is contained in:
李龙 2025-01-22 16:52:59 +08:00
parent fc6dad57c8
commit f16704bba5
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
View File

@ -80,7 +80,11 @@ public class RocketMQEventConfiguration {
@Override @Override
public void onMessage(MessageExt message) { public void onMessage(MessageExt message) {
super.onEvent(message, eventConsumer); try {
super.onEvent(message, eventConsumer);
} catch (Exception ex) {
log.warn("consumer thrones message error,", ex);
}
} }
} }
@ -99,7 +103,11 @@ public class RocketMQEventConfiguration {
@Override @Override
public void onMessage(MessageExt message) { public void onMessage(MessageExt message) {
super.onEvent(message, eventConsumer); try {
super.onEvent(message, eventConsumer);
} catch (Exception ex) {
log.warn("consumer tyr message error,", ex);
}
} }
} }
@ -118,7 +126,11 @@ public class RocketMQEventConfiguration {
@Override @Override
public void onMessage(MessageExt message) { public void onMessage(MessageExt message) {
super.onEvent(message, eventConsumer); try {
super.onEvent(message, eventConsumer);
} catch (Exception ex) {
log.warn("consumer apisixPlat message error,", ex);
}
} }
} }