wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3502: 消息者隔离

Browse Source
This commit is contained in:
yanglin 2025-01-17 11:38:32 +08:00
parent 11e21abee2
commit dee81decd6
5 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/CardPresetButtonSyncTodoListener.java
View File

@ -5,6 +5,7 @@ import cn.axzo.framework.rocketmq.EventConsumer;
import cn.axzo.msg.center.api.mq.CardPresetButtonPressedMessage; import cn.axzo.msg.center.api.mq.CardPresetButtonPressedMessage;
import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.ConsumerIsolation;
import cn.axzo.msg.center.mq.IsolationMQListener; import cn.axzo.msg.center.mq.IsolationMQListener;
import cn.axzo.msg.center.mq.RocketMQConfig;
import cn.axzo.msg.center.service.enums.MqMessageType; import cn.axzo.msg.center.service.enums.MqMessageType;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.ConsumeMode; import org.apache.rocketmq.spring.annotation.ConsumeMode;
@ -20,7 +21,7 @@ import org.springframework.stereotype.Component;
maxReconsumeTimes = 3, maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", 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}" consumerGroup = "GID_topic_card_preset_button_sync_todo_${spring.profiles.active}"
) )
public class CardPresetButtonSyncTodoListener extends IsolationMQListener { public class CardPresetButtonSyncTodoListener extends IsolationMQListener {

3
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoPresetButtonSyncCardListener.java
View File

@ -5,6 +5,7 @@ import cn.axzo.framework.rocketmq.EventConsumer;
import cn.axzo.msg.center.api.mq.PresetButtonPressedMessage; import cn.axzo.msg.center.api.mq.PresetButtonPressedMessage;
import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.ConsumerIsolation;
import cn.axzo.msg.center.mq.IsolationMQListener; import cn.axzo.msg.center.mq.IsolationMQListener;
import cn.axzo.msg.center.mq.RocketMQConfig;
import cn.axzo.msg.center.service.enums.MqMessageType; import cn.axzo.msg.center.service.enums.MqMessageType;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.ConsumeMode; import org.apache.rocketmq.spring.annotation.ConsumeMode;
@ -20,7 +21,7 @@ import org.springframework.stereotype.Component;
maxReconsumeTimes = 3, maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", 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}" consumerGroup = "GID_topic_todo_preset_button_sync_card_${spring.profiles.active}"
) )
public class TodoPresetButtonSyncCardListener extends IsolationMQListener { public class TodoPresetButtonSyncCardListener extends IsolationMQListener {

3
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardBizListener.java
View File

@ -5,6 +5,7 @@ import cn.axzo.framework.rocketmq.EventConsumer;
import cn.axzo.msg.center.api.mq.TodoUpdateMessage; import cn.axzo.msg.center.api.mq.TodoUpdateMessage;
import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.ConsumerIsolation;
import cn.axzo.msg.center.mq.IsolationMQListener; 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.BizCategoryEnum;
import cn.axzo.msg.center.service.enums.MqMessageType; import cn.axzo.msg.center.service.enums.MqMessageType;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -21,7 +22,7 @@ import org.springframework.stereotype.Component;
maxReconsumeTimes = 3, maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", 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}" consumerGroup = "GID_topic_todo_sync_card_biz_${spring.profiles.active}"
) )
class TodoSyncCardBizListener extends IsolationMQListener { class TodoSyncCardBizListener extends IsolationMQListener {

3
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardFlowListener.java
View File

@ -5,6 +5,7 @@ import cn.axzo.framework.rocketmq.EventConsumer;
import cn.axzo.msg.center.api.mq.TodoUpdateMessage; import cn.axzo.msg.center.api.mq.TodoUpdateMessage;
import cn.axzo.msg.center.mq.ConsumerIsolation; import cn.axzo.msg.center.mq.ConsumerIsolation;
import cn.axzo.msg.center.mq.IsolationMQListener; 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.BizCategoryEnum;
import cn.axzo.msg.center.service.enums.MqMessageType; import cn.axzo.msg.center.service.enums.MqMessageType;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -21,7 +22,7 @@ import org.springframework.stereotype.Component;
maxReconsumeTimes = 3, maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", 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}" consumerGroup = "GID_topic_todo_sync_card_flow_${spring.profiles.active}"
) )
class TodoSyncCardFlowListener extends IsolationMQListener { class TodoSyncCardFlowListener extends IsolationMQListener {

3
inside-notices/src/main/java/cn/axzo/msg/center/mq/RocketMQConfig.java
View File

@ -40,8 +40,9 @@ import java.util.function.Consumer;
public class RocketMQConfig { public class RocketMQConfig {
public static final String APP_NAME = "MSG-CENTER"; 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; private String topic;
@Bean @Bean