wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3502: 设置重试数据

Browse Source
This commit is contained in:
yanglin 2025-01-15 11:49:41 +08:00
parent 8502fa85e9
commit 680f7a13e5
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
inside-notices/src/main/java/cn/axzo/msg/center/mq/RocketMQConfig.java
View File

@ -148,7 +148,8 @@ public class RocketMQConfig {
@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}",
consumerGroup = "GID_topic_card_sync_todo_${spring.profiles.active}",
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}"
nameServer = "${rocketmq.name-server}",
maxReconsumeTimes = 3
)
public static class CardSyncTodoListener extends BaseListener implements RocketMQListener<MessageExt> {
@ -166,7 +167,8 @@ public class RocketMQConfig {
@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}",
consumerGroup = "GID_topic_todo_sync_card_biz_${spring.profiles.active}",
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}"
nameServer = "${rocketmq.name-server}",
maxReconsumeTimes = 3
)
public static class TodoSyncCardBizListener extends BaseListener implements RocketMQListener<MessageExt> {
@ -189,7 +191,8 @@ public class RocketMQConfig {
@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}",
consumerGroup = "GID_topic_todo_sync_card_flow_${spring.profiles.active}",
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}"
nameServer = "${rocketmq.name-server}",
maxReconsumeTimes = 3
)
public static class TodoSyncCardFlowListener extends BaseListener implements RocketMQListener<MessageExt> {