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 {