diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/mq/RocketMQConfig.java b/inside-notices/src/main/java/cn/axzo/msg/center/mq/RocketMQConfig.java index f3118e27..bbbc248c 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/mq/RocketMQConfig.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/mq/RocketMQConfig.java @@ -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 { @@ -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 { @@ -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 {