wangli/tyr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:(feature/REQ-3342) 消费消息改成顺序消费，

Browse Source
This commit is contained in:
李龙 2025-01-22 18:10:02 +08:00
parent 758e20ef88
commit 0b22477ca4
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
View File

@ -71,7 +71,6 @@ public class RocketMQEventConfiguration {
@RocketMQMessageListener(topic = "topic_thrones_${spring.profiles.active}", @RocketMQMessageListener(topic = "topic_thrones_${spring.profiles.active}",
consumerGroup = "GID_topic_thrones_${spring.application.name}_${spring.profiles.active}", consumerGroup = "GID_topic_thrones_${spring.application.name}_${spring.profiles.active}",
messageModel = MessageModel.BROADCASTING, messageModel = MessageModel.BROADCASTING,
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"
) )
public static class ThronesListener extends BaseListener implements RocketMQListener<MessageExt> { public static class ThronesListener extends BaseListener implements RocketMQListener<MessageExt> {
@ -114,7 +113,6 @@ public class RocketMQEventConfiguration {
@RocketMQMessageListener(topic = "topic_tyr_${spring.profiles.active}", @RocketMQMessageListener(topic = "topic_tyr_${spring.profiles.active}",
consumerGroup = "GID_topic_tyr_${spring.application.name}_${spring.profiles.active}", consumerGroup = "GID_topic_tyr_${spring.application.name}_${spring.profiles.active}",
messageModel = MessageModel.BROADCASTING, messageModel = MessageModel.BROADCASTING,
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"
) )
public static class TyrListener extends BaseListener implements RocketMQListener<MessageExt> { public static class TyrListener extends BaseListener implements RocketMQListener<MessageExt> {
@ -157,7 +155,6 @@ public class RocketMQEventConfiguration {
@RocketMQMessageListener(topic = "topic_apisix_plat_${spring.profiles.active}", @RocketMQMessageListener(topic = "topic_apisix_plat_${spring.profiles.active}",
consumerGroup = "GID_topic_apisix_plat_${spring.application.name}_${spring.profiles.active}", consumerGroup = "GID_topic_apisix_plat_${spring.application.name}_${spring.profiles.active}",
messageModel = MessageModel.BROADCASTING, messageModel = MessageModel.BROADCASTING,
consumeMode = ConsumeMode.ORDERLY,
nameServer = "${rocketmq.name-server}" nameServer = "${rocketmq.name-server}"
) )
public static class ApiSixPlatListener extends BaseListener implements RocketMQListener<MessageExt> { public static class ApiSixPlatListener extends BaseListener implements RocketMQListener<MessageExt> {