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