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 17:49:40 +08:00
parent c1c75930d6
commit 758e20ef88
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -71,6 +71,7 @@ public class RocketMQEventConfiguration {
@RocketMQMessageListener(topic = "topic_thrones_${spring.profiles.active}", @RocketMQMessageListener(topic = "topic_thrones_${spring.profiles.active}",
consumerGroup = "GID_topic_thrones_${spring.application.name}_${spring.profiles.active}", consumerGroup = "GID_topic_thrones_${spring.application.name}_${spring.profiles.active}",
messageModel = MessageModel.BROADCASTING, messageModel = MessageModel.BROADCASTING,
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"
) )
public static class ThronesListener extends BaseListener implements RocketMQListener<MessageExt> { public static class ThronesListener extends BaseListener implements RocketMQListener<MessageExt> {
@ -113,6 +114,7 @@ public class RocketMQEventConfiguration {
@RocketMQMessageListener(topic = "topic_tyr_${spring.profiles.active}", @RocketMQMessageListener(topic = "topic_tyr_${spring.profiles.active}",
consumerGroup = "GID_topic_tyr_${spring.application.name}_${spring.profiles.active}", consumerGroup = "GID_topic_tyr_${spring.application.name}_${spring.profiles.active}",
messageModel = MessageModel.BROADCASTING, messageModel = MessageModel.BROADCASTING,
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"
) )
public static class TyrListener extends BaseListener implements RocketMQListener<MessageExt> { public static class TyrListener extends BaseListener implements RocketMQListener<MessageExt> {
@ -155,6 +157,7 @@ public class RocketMQEventConfiguration {
@RocketMQMessageListener(topic = "topic_apisix_plat_${spring.profiles.active}", @RocketMQMessageListener(topic = "topic_apisix_plat_${spring.profiles.active}",
consumerGroup = "GID_topic_apisix_plat_${spring.application.name}_${spring.profiles.active}", consumerGroup = "GID_topic_apisix_plat_${spring.application.name}_${spring.profiles.active}",
messageModel = MessageModel.BROADCASTING, messageModel = MessageModel.BROADCASTING,
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"
) )
public static class ApiSixPlatListener extends BaseListener implements RocketMQListener<MessageExt> { public static class ApiSixPlatListener extends BaseListener implements RocketMQListener<MessageExt> {