From 7a50a808c648c5563a6d0eb086094324c3024521 Mon Sep 17 00:00:00 2001 From: yanglin Date: Fri, 17 Jan 2025 11:13:07 +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 --- ... => CardPresetButtonSyncTodoListener.java} | 12 ++- ... => TodoPresetButtonSyncCardListener.java} | 12 ++- ...dler.java => TodoSyncCardBizListener.java} | 12 ++- ...ler.java => TodoSyncCardFlowListener.java} | 12 ++- .../cn/axzo/msg/center/mq/RocketMQConfig.java | 96 ------------------- 5 files changed, 40 insertions(+), 104 deletions(-) rename inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/{CardPresetButtonSyncTodoHandler.java => CardPresetButtonSyncTodoListener.java} (65%) rename inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/{TodoPresetButtonSyncCardHandler.java => TodoPresetButtonSyncCardListener.java} (64%) rename inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/{TodoSyncCardBizHandler.java => TodoSyncCardBizListener.java} (69%) rename inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/{TodoSyncCardFlowHandler.java => TodoSyncCardFlowListener.java} (69%) diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoHandler.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoListener.java similarity index 65% rename from inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoHandler.java rename to inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoListener.java index 87021205..df4565ed 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoHandler.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoListener.java @@ -7,6 +7,8 @@ import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.IsolationMQListener; import cn.axzo.msg.center.service.enums.MqMessageType; import lombok.extern.slf4j.Slf4j; +import org.apache.rocketmq.spring.annotation.ConsumeMode; +import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.springframework.stereotype.Component; /** @@ -14,11 +16,17 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component -public class CardPresetButtonSyncTodoHandler extends IsolationMQListener { +@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", + consumerGroup = "GID_topic_card_preset_button_sync_todo_${spring.profiles.active}", + consumeMode = ConsumeMode.ORDERLY, + nameServer = "${rocketmq.name-server}", + maxReconsumeTimes = 3 +) +public class CardPresetButtonSyncTodoListener extends IsolationMQListener { private final TodoSyncCardService todoSyncCardService; - CardPresetButtonSyncTodoHandler(TodoSyncCardService todoSyncCardService) { + CardPresetButtonSyncTodoListener(TodoSyncCardService todoSyncCardService) { super(ConsumerIsolation.CARD_PRESET_BUTTON_CLICKED_SYNC_TODO, MqMessageType.CARD_PRESET_BUTTON_PRESSED); this.todoSyncCardService = todoSyncCardService; diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardHandler.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardListener.java similarity index 64% rename from inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardHandler.java rename to inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardListener.java index c681f116..f57f09bc 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardHandler.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardListener.java @@ -7,6 +7,8 @@ import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.IsolationMQListener; import cn.axzo.msg.center.service.enums.MqMessageType; import lombok.extern.slf4j.Slf4j; +import org.apache.rocketmq.spring.annotation.ConsumeMode; +import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.springframework.stereotype.Component; /** @@ -14,11 +16,17 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component -public class TodoPresetButtonSyncCardHandler extends IsolationMQListener { +@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", + consumerGroup = "GID_topic_todo_preset_button_sync_card_${spring.profiles.active}", + consumeMode = ConsumeMode.ORDERLY, + nameServer = "${rocketmq.name-server}", + maxReconsumeTimes = 3 +) +public class TodoPresetButtonSyncCardListener extends IsolationMQListener { private final TodoSyncCardService todoSyncCardService; - TodoPresetButtonSyncCardHandler(TodoSyncCardService todoSyncCardService) { + TodoPresetButtonSyncCardListener(TodoSyncCardService todoSyncCardService) { super(ConsumerIsolation.TODO_PRESET_BUTTON_CLICKED_SYNC_CARD, MqMessageType.TODO_PRESET_BUTTON_PRESSED); this.todoSyncCardService = todoSyncCardService; diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizHandler.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizListener.java similarity index 69% rename from inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizHandler.java rename to inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizListener.java index e3b09bcc..6cce3b2b 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizHandler.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizListener.java @@ -8,6 +8,8 @@ import cn.axzo.msg.center.mq.IsolationMQListener; import cn.axzo.msg.center.service.enums.BizCategoryEnum; import cn.axzo.msg.center.service.enums.MqMessageType; import lombok.extern.slf4j.Slf4j; +import org.apache.rocketmq.spring.annotation.ConsumeMode; +import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.springframework.stereotype.Component; /** @@ -15,11 +17,17 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component -class TodoSyncCardBizHandler extends IsolationMQListener { +@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}", + maxReconsumeTimes = 3 +) +class TodoSyncCardBizListener extends IsolationMQListener { private final TodoSyncCardService todoSyncCardService; - TodoSyncCardBizHandler(TodoSyncCardService todoSyncCardService) { + TodoSyncCardBizListener(TodoSyncCardService todoSyncCardService) { super(ConsumerIsolation.TODO_SYNC_CARD_BIZ, MqMessageType.TODO_STATE_UPDATE); this.todoSyncCardService = todoSyncCardService; } diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowHandler.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowListener.java similarity index 69% rename from inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowHandler.java rename to inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowListener.java index 900eb7a7..bd4b8374 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowHandler.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowListener.java @@ -8,6 +8,8 @@ import cn.axzo.msg.center.mq.IsolationMQListener; import cn.axzo.msg.center.service.enums.BizCategoryEnum; import cn.axzo.msg.center.service.enums.MqMessageType; import lombok.extern.slf4j.Slf4j; +import org.apache.rocketmq.spring.annotation.ConsumeMode; +import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.springframework.stereotype.Component; /** @@ -15,11 +17,17 @@ import org.springframework.stereotype.Component; */ @Slf4j @Component -class TodoSyncCardFlowHandler extends IsolationMQListener { +@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}", + maxReconsumeTimes = 3 +) +class TodoSyncCardFlowListener extends IsolationMQListener { private final TodoSyncCardService todoSyncCardService; - TodoSyncCardFlowHandler(TodoSyncCardService todoSyncCardService) { + TodoSyncCardFlowListener(TodoSyncCardService todoSyncCardService) { super(ConsumerIsolation.TODO_SYNC_CARD_FLOW, MqMessageType.TODO_STATE_UPDATE); this.todoSyncCardService = todoSyncCardService; } 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 c1f70e84..8c0fdc1a 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 @@ -139,100 +139,4 @@ public class RocketMQConfig { }); } - @Slf4j - @Component - @RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", - consumerGroup = "GID_topic_card_preset_button_sync_todo_${spring.profiles.active}", - consumeMode = ConsumeMode.ORDERLY, - nameServer = "${rocketmq.name-server}", - maxReconsumeTimes = 3 - ) - public static class CardPresetButtonSyncTodoListener extends BaseListener implements RocketMQListener { - - @Autowired - private EventConsumer eventConsumer; - - @Override - public void onMessage(MessageExt message) { - ConsumerIsolation.setIsolation(ConsumerIsolation.CARD_PRESET_BUTTON_CLICKED_SYNC_TODO); - try { - super.onEvent(message, eventConsumer); - } finally { - ConsumerIsolation.clearIsolation(); - } - } - } - - @Slf4j - @Component - @RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", - consumerGroup = "GID_topic_todo_preset_button_sync_card_${spring.profiles.active}", - consumeMode = ConsumeMode.ORDERLY, - nameServer = "${rocketmq.name-server}", - maxReconsumeTimes = 3 - ) - public static class TodoPresetButtonSyncCardListener extends BaseListener implements RocketMQListener { - - @Autowired - private EventConsumer eventConsumer; - - @Override - public void onMessage(MessageExt message) { - ConsumerIsolation.setIsolation(ConsumerIsolation.TODO_PRESET_BUTTON_CLICKED_SYNC_CARD); - try { - super.onEvent(message, eventConsumer); - } finally { - ConsumerIsolation.clearIsolation(); - } - } - } - - @Slf4j - @Component - @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}", - maxReconsumeTimes = 3 - ) - public static class TodoSyncCardBizListener extends BaseListener implements RocketMQListener { - - @Autowired - private EventConsumer eventConsumer; - - @Override - public void onMessage(MessageExt message) { - ConsumerIsolation.setIsolation(ConsumerIsolation.TODO_SYNC_CARD_BIZ); - try { - super.onEvent(message, eventConsumer); - } finally { - ConsumerIsolation.clearIsolation(); - } - } - } - - @Slf4j - @Component - @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}", - maxReconsumeTimes = 3 - ) - public static class TodoSyncCardFlowListener extends BaseListener implements RocketMQListener { - - @Autowired - private EventConsumer eventConsumer; - - @Override - public void onMessage(MessageExt message) { - ConsumerIsolation.setIsolation(ConsumerIsolation.TODO_SYNC_CARD_FLOW); - try { - super.onEvent(message, eventConsumer); - } finally { - ConsumerIsolation.clearIsolation(); - } - } - } - } \ No newline at end of file