From 11e21abee27c5aae7ad6eeb5cd0dbb0ca358f78f Mon Sep 17 00:00:00 2001 From: yanglin Date: Fri, 17 Jan 2025 11:15:53 +0800 Subject: [PATCH] =?UTF-8?q?REQ-3502:=20=E6=B6=88=E6=81=AF=E8=80=85?= =?UTF-8?q?=E9=9A=94=E7=A6=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../todo/card/CardPresetButtonSyncTodoListener.java | 7 ++++--- .../todo/card/TodoPresetButtonSyncCardListener.java | 7 ++++--- .../message/service/todo/card/TodoSyncCardBizListener.java | 7 ++++--- .../service/todo/card/TodoSyncCardFlowListener.java | 7 ++++--- 4 files changed, 16 insertions(+), 12 deletions(-) diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoListener.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoListener.java index df4565ed..4fc4d822 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoListener.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoListener.java @@ -16,11 +16,12 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component -@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", - consumerGroup = "GID_topic_card_preset_button_sync_todo_${spring.profiles.active}", +@RocketMQMessageListener( + maxReconsumeTimes = 3, consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}", - maxReconsumeTimes = 3 + topic = "topic_msg_center_${spring.profiles.active}", + consumerGroup = "GID_topic_card_preset_button_sync_todo_${spring.profiles.active}" ) public class CardPresetButtonSyncTodoListener extends IsolationMQListener { diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardListener.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardListener.java index f57f09bc..eed0a0ec 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardListener.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardListener.java @@ -16,11 +16,12 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component -@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", - consumerGroup = "GID_topic_todo_preset_button_sync_card_${spring.profiles.active}", +@RocketMQMessageListener( + maxReconsumeTimes = 3, consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}", - maxReconsumeTimes = 3 + topic = "topic_msg_center_${spring.profiles.active}", + consumerGroup = "GID_topic_todo_preset_button_sync_card_${spring.profiles.active}" ) public class TodoPresetButtonSyncCardListener extends IsolationMQListener { diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizListener.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizListener.java index 6cce3b2b..b15c6c18 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizListener.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizListener.java @@ -17,11 +17,12 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component -@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", - consumerGroup = "GID_topic_todo_sync_card_biz_${spring.profiles.active}", +@RocketMQMessageListener( + maxReconsumeTimes = 3, consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}", - maxReconsumeTimes = 3 + topic = "topic_msg_center_${spring.profiles.active}", + consumerGroup = "GID_topic_todo_sync_card_biz_${spring.profiles.active}" ) class TodoSyncCardBizListener extends IsolationMQListener { diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowListener.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowListener.java index bd4b8374..b9da1cce 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowListener.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowListener.java @@ -17,11 +17,12 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component -@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", - consumerGroup = "GID_topic_todo_sync_card_flow_${spring.profiles.active}", +@RocketMQMessageListener( + maxReconsumeTimes = 3, consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}", - maxReconsumeTimes = 3 + topic = "topic_msg_center_${spring.profiles.active}", + consumerGroup = "GID_topic_todo_sync_card_flow_${spring.profiles.active}" ) class TodoSyncCardFlowListener extends IsolationMQListener {