by2025/SmartParks
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(rocketmq): 手动装配rocketMQ

Browse Source
This commit is contained in:
zcxlsm
2025-08-26 21:02:38 +08:00
parent 07b9e8b722
commit 3ebc58f5e3
4 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
ruoyi-modules/Sis/src/main/java/org/dromara/sis/config/RocketMQClusterConfig.java
View File

@@ -16,10 +16,10 @@ import org.springframework.context.annotation.Configuration;
public class RocketMQClusterConfig { public class RocketMQClusterConfig {
// 从配置文件中读取 cluster 的配置 // 从配置文件中读取 cluster 的配置
@Value("${rocketmq1.cluster.name-server}") @Value("${rocketmq.cluster1.name-server}")
private String nameServer1; private String nameServer1;
@Value("${rocketmq1.cluster.producer.group}") @Value("${rocketmq.cluster1.producer.group}")
private String producerGroup1; private String producerGroup1;
// 为第一个集群创建生产者实例 // 为第一个集群创建生产者实例
@@ -45,10 +45,10 @@ public class RocketMQClusterConfig {
// 从配置文件中读取 cluster 的配置 // 从配置文件中读取 cluster 的配置
@Value("${rocketmq2.cluster.name-server}") @Value("${rocketmq.cluster2.name-server}")
private String nameServer2; private String nameServer2;
@Value("${rocketmq2.cluster.producer.group}") @Value("${rocketmq.cluster2.producer.group}")
private String producerGroup2; private String producerGroup2;
// 为第二个集群创建生产者实例 // 为第二个集群创建生产者实例

2
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCaptureConsumer.java
View File

@@ -25,7 +25,7 @@ import org.springframework.stereotype.Component;
topic = RocketMqConstants.TOPIC, topic = RocketMqConstants.TOPIC,
consumerGroup = RocketMqConstants.GROUP, consumerGroup = RocketMqConstants.GROUP,
selectorExpression = RocketMqConstants.FACECAPTURE, selectorExpression = RocketMqConstants.FACECAPTURE,
nameServer = "${rocketmq2.cluster.name-server}" nameServer = "${rocketmq.cluster2.name-server}"
) )
public class FaceCaptureConsumer implements RocketMQListener<MessageExt> { public class FaceCaptureConsumer implements RocketMQListener<MessageExt> {

2
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/FaceCompareConsumer.java
View File

@@ -23,7 +23,7 @@ import org.springframework.stereotype.Component;
topic = RocketMqConstants.TOPIC, topic = RocketMqConstants.TOPIC,
consumerGroup = RocketMqConstants.GROUP, consumerGroup = RocketMqConstants.GROUP,
selectorExpression = RocketMqConstants.FACECOMPARE, selectorExpression = RocketMqConstants.FACECOMPARE,
nameServer = "${rocketmq2.cluster.name-server}" nameServer = "${rocketmq.cluster2.name-server}"
) )
public class FaceCompareConsumer implements RocketMQListener<MessageExt> { public class FaceCompareConsumer implements RocketMQListener<MessageExt> {

2
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java
View File

@@ -20,7 +20,7 @@ import org.springframework.stereotype.Component;
consumerGroup = "Meter_Group", consumerGroup = "Meter_Group",
topic = RocketMqConstants.TOPIC, topic = RocketMqConstants.TOPIC,
selectorExpression = RocketMqConstants.METER_RECORD, selectorExpression = RocketMqConstants.METER_RECORD,
nameServer = "${rocketmq2.cluster.name-server}" nameServer = "${rocketmq.cluster2.name-server}"
) )
public class MeterRecordConsumer implements RocketMQListener<MessageExt> { public class MeterRecordConsumer implements RocketMQListener<MessageExt> {