From dee81decd6f817c856abbe3e96ca791d352e518d Mon Sep 17 00:00:00 2001 From: yanglin Date: Fri, 17 Jan 2025 11:38:32 +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 --- .../service/todo/card/CardPresetButtonSyncTodoListener.java | 3 ++- .../service/todo/card/TodoPresetButtonSyncCardListener.java | 3 ++- .../message/service/todo/card/TodoSyncCardBizListener.java | 3 ++- .../message/service/todo/card/TodoSyncCardFlowListener.java | 3 ++- .../src/main/java/cn/axzo/msg/center/mq/RocketMQConfig.java | 3 ++- 5 files changed, 10 insertions(+), 5 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 4fc4d822..0bdb69f4 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 @@ -5,6 +5,7 @@ import cn.axzo.framework.rocketmq.EventConsumer; import cn.axzo.msg.center.api.mq.CardPresetButtonPressedMessage; import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.IsolationMQListener; +import cn.axzo.msg.center.mq.RocketMQConfig; import cn.axzo.msg.center.service.enums.MqMessageType; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.spring.annotation.ConsumeMode; @@ -20,7 +21,7 @@ import org.springframework.stereotype.Component; maxReconsumeTimes = 3, consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}", - topic = "topic_msg_center_${spring.profiles.active}", + topic = RocketMQConfig.MSG_CENTER_TOPIC, 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 eed0a0ec..330a4fcf 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 @@ -5,6 +5,7 @@ import cn.axzo.framework.rocketmq.EventConsumer; import cn.axzo.msg.center.api.mq.PresetButtonPressedMessage; import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.IsolationMQListener; +import cn.axzo.msg.center.mq.RocketMQConfig; import cn.axzo.msg.center.service.enums.MqMessageType; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.spring.annotation.ConsumeMode; @@ -20,7 +21,7 @@ import org.springframework.stereotype.Component; maxReconsumeTimes = 3, consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}", - topic = "topic_msg_center_${spring.profiles.active}", + topic = RocketMQConfig.MSG_CENTER_TOPIC, 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 b15c6c18..a0123cd8 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 @@ -5,6 +5,7 @@ import cn.axzo.framework.rocketmq.EventConsumer; import cn.axzo.msg.center.api.mq.TodoUpdateMessage; import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.IsolationMQListener; +import cn.axzo.msg.center.mq.RocketMQConfig; import cn.axzo.msg.center.service.enums.BizCategoryEnum; import cn.axzo.msg.center.service.enums.MqMessageType; import lombok.extern.slf4j.Slf4j; @@ -21,7 +22,7 @@ import org.springframework.stereotype.Component; maxReconsumeTimes = 3, consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}", - topic = "topic_msg_center_${spring.profiles.active}", + topic = RocketMQConfig.MSG_CENTER_TOPIC, 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 b9da1cce..efcf006a 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 @@ -5,6 +5,7 @@ import cn.axzo.framework.rocketmq.EventConsumer; import cn.axzo.msg.center.api.mq.TodoUpdateMessage; import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.IsolationMQListener; +import cn.axzo.msg.center.mq.RocketMQConfig; import cn.axzo.msg.center.service.enums.BizCategoryEnum; import cn.axzo.msg.center.service.enums.MqMessageType; import lombok.extern.slf4j.Slf4j; @@ -21,7 +22,7 @@ import org.springframework.stereotype.Component; maxReconsumeTimes = 3, consumeMode = ConsumeMode.ORDERLY, nameServer = "${rocketmq.name-server}", - topic = "topic_msg_center_${spring.profiles.active}", + topic = RocketMQConfig.MSG_CENTER_TOPIC, consumerGroup = "GID_topic_todo_sync_card_flow_${spring.profiles.active}" ) class TodoSyncCardFlowListener extends IsolationMQListener { 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 8c0fdc1a..94df03a4 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 @@ -40,8 +40,9 @@ import java.util.function.Consumer; public class RocketMQConfig { public static final String APP_NAME = "MSG-CENTER"; + public static final String MSG_CENTER_TOPIC = "topic_msg_center_${spring.profiles.active}"; - @Value("topic_msg_center_${spring.profiles.active}") + @Value(MSG_CENTER_TOPIC) private String topic; @Bean