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

feat: (feature/REQ-3591) 修改消费RETRY topic的消费组名字

Browse Source
This commit is contained in:
李龙 2025-03-20 09:39:33 +08:00
parent 41b55850a9
commit 5bd53eeef7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -88,7 +88,7 @@ public class RocketMQEventConfiguration {
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener(topic = "%RETRY%GID_topic_thrones_${spring.profiles.active}", @RocketMQMessageListener(topic = "%RETRY%GID_topic_thrones_${spring.profiles.active}",
consumerGroup = "GID_topic_thrones_${spring.application.name}_${spring.profiles.active}", consumerGroup = "GID_topic_thrones_retry_${spring.application.name}_${spring.profiles.active}",
messageModel = MessageModel.BROADCASTING, messageModel = MessageModel.BROADCASTING,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"
) )
@ -130,7 +130,7 @@ public class RocketMQEventConfiguration {
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener(topic = "%RETRY%GID_topic_tyr_${spring.profiles.active}", @RocketMQMessageListener(topic = "%RETRY%GID_topic_tyr_${spring.profiles.active}",
consumerGroup = "GID_topic_tyr_${spring.application.name}_${spring.profiles.active}", consumerGroup = "GID_topic_tyr_retry_${spring.application.name}_${spring.profiles.active}",
messageModel = MessageModel.BROADCASTING, messageModel = MessageModel.BROADCASTING,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"
) )
@ -176,7 +176,7 @@ public class RocketMQEventConfiguration {
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener(topic = "%RETRY%GID_topic_apisix_plat_${spring.profiles.active}", @RocketMQMessageListener(topic = "%RETRY%GID_topic_apisix_plat_${spring.profiles.active}",
consumerGroup = "GID_topic_apisix_plat_${spring.application.name}_${spring.profiles.active}", consumerGroup = "GID_topic_apisix_plat_retry_${spring.application.name}_${spring.profiles.active}",
messageModel = MessageModel.BROADCASTING, messageModel = MessageModel.BROADCASTING,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"
) )