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:15:53 +08:00
parent 7a50a808c6
commit 11e21abee2
4 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -16,11 +16,12 @@ import org.springframework.stereotype.Component;
*/ */
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", @RocketMQMessageListener(
consumerGroup = "GID_topic_card_preset_button_sync_todo_${spring.profiles.active}", maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", 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 { public class CardPresetButtonSyncTodoListener extends IsolationMQListener {

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

@ -16,11 +16,12 @@ import org.springframework.stereotype.Component;
*/ */
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", @RocketMQMessageListener(
consumerGroup = "GID_topic_todo_preset_button_sync_card_${spring.profiles.active}", maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", 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 { public class TodoPresetButtonSyncCardListener extends IsolationMQListener {

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

@ -17,11 +17,12 @@ import org.springframework.stereotype.Component;
*/ */
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", @RocketMQMessageListener(
consumerGroup = "GID_topic_todo_sync_card_biz_${spring.profiles.active}", maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", 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 { class TodoSyncCardBizListener extends IsolationMQListener {

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

@ -17,11 +17,12 @@ import org.springframework.stereotype.Component;
*/ */
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener(topic = "topic_msg_center_${spring.profiles.active}", @RocketMQMessageListener(
consumerGroup = "GID_topic_todo_sync_card_flow_${spring.profiles.active}", maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", 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 { class TodoSyncCardFlowListener extends IsolationMQListener {