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 15:17:16 +08:00
parent dee81decd6
commit 9435365317
4 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -18,6 +18,7 @@ import org.springframework.stereotype.Component;
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener( @RocketMQMessageListener(
consumeThreadMax = 2,
maxReconsumeTimes = 3, maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", nameServer = "${rocketmq.name-server}",

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

@ -18,6 +18,7 @@ import org.springframework.stereotype.Component;
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener( @RocketMQMessageListener(
consumeThreadMax = 2,
maxReconsumeTimes = 3, maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", nameServer = "${rocketmq.name-server}",

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

@ -19,6 +19,7 @@ import org.springframework.stereotype.Component;
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener( @RocketMQMessageListener(
consumeThreadMax = 2,
maxReconsumeTimes = 3, maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", nameServer = "${rocketmq.name-server}",

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

@ -19,6 +19,7 @@ import org.springframework.stereotype.Component;
@Slf4j @Slf4j
@Component @Component
@RocketMQMessageListener( @RocketMQMessageListener(
consumeThreadMax = 2,
maxReconsumeTimes = 3, maxReconsumeTimes = 3,
consumeMode = ConsumeMode.ORDERLY, consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}", nameServer = "${rocketmq.name-server}",