From 3ebc58f5e371ecc8d487fe04da547be835a61016 Mon Sep 17 00:00:00 2001 From: zcxlsm Date: Tue, 26 Aug 2025 21:02:38 +0800 Subject: [PATCH] =?UTF-8?q?refactor(rocketmq):=20=E6=89=8B=E5=8A=A8?= =?UTF-8?q?=E8=A3=85=E9=85=8DrocketMQ?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../org/dromara/sis/config/RocketMQClusterConfig.java | 8 ++++---- .../sis/rocketmq/consumer/FaceCaptureConsumer.java | 2 +- .../sis/rocketmq/consumer/FaceCompareConsumer.java | 2 +- .../sis/rocketmq/consumer/MeterRecordConsumer.java | 2 +- 4 files changed, 7 insertions(+), 7 deletions(-) diff --git a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/config/RocketMQClusterConfig.java b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/config/RocketMQClusterConfig.java index 9e300b38..5c115981 100644 --- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/config/RocketMQClusterConfig.java +++ b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/config/RocketMQClusterConfig.java @@ -16,10 +16,10 @@ import org.springframework.context.annotation.Configuration; public class RocketMQClusterConfig { // 从配置文件中读取 cluster 的配置 - @Value("${rocketmq1.cluster.name-server}") + @Value("${rocketmq.cluster1.name-server}") private String nameServer1; - @Value("${rocketmq1.cluster.producer.group}") + @Value("${rocketmq.cluster1.producer.group}") private String producerGroup1; // 为第一个集群创建生产者实例 @@ -45,10 +45,10 @@ public class RocketMQClusterConfig { // 从配置文件中读取 cluster 的配置 - @Value("${rocketmq2.cluster.name-server}") + @Value("${rocketmq.cluster2.name-server}") private String nameServer2; - @Value("${rocketmq2.cluster.producer.group}") + @Value("${rocketmq.cluster2.producer.group}") private String producerGroup2; // 为第二个集群创建生产者实例 diff --git a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java index 2779d4dd..94330117 100644 --- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java +++ b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java @@ -25,7 +25,7 @@ import org.springframework.stereotype.Component; topic = RocketMqConstants.TOPIC, consumerGroup = RocketMqConstants.GROUP, selectorExpression = RocketMqConstants.FACECAPTURE, - nameServer = "${rocketmq2.cluster.name-server}" + nameServer = "${rocketmq.cluster2.name-server}" ) public class FaceCaptureConsumer implements RocketMQListener { diff --git a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java index c9f50b2f..e4b0faa7 100644 --- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java +++ b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java @@ -23,7 +23,7 @@ import org.springframework.stereotype.Component; topic = RocketMqConstants.TOPIC, consumerGroup = RocketMqConstants.GROUP, selectorExpression = RocketMqConstants.FACECOMPARE, - nameServer = "${rocketmq2.cluster.name-server}" + nameServer = "${rocketmq.cluster2.name-server}" ) public class FaceCompareConsumer implements RocketMQListener { diff --git a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java index 734e71b5..aa1a0fd2 100644 --- a/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java +++ b/ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java @@ -20,7 +20,7 @@ import org.springframework.stereotype.Component; consumerGroup = "Meter_Group", topic = RocketMqConstants.TOPIC, selectorExpression = RocketMqConstants.METER_RECORD, - nameServer = "${rocketmq2.cluster.name-server}" + nameServer = "${rocketmq.cluster2.name-server}" ) public class MeterRecordConsumer implements RocketMQListener {