场景计算拆分

4dkankan-center-modeling/src/main/java/com/fdkankan/modeling/receiver/BuildSceneListener.java

@@ -73,23 +73,23 @@ import org.springframework.web.client.RestTemplate;
 @Slf4j
 @Component
 @RocketMQMessageListener(
-        consumerGroup = "${rocketmq.consumer.build-scene-group}",
-        topic = "${rocketmq.build-scene.topicName.topic-modeling-a}",
+        consumerGroup = "${rocketmq.consumer.build-scene-group-test}",
+        topic = "${rocketmq.build-scene.topicName.topic-modeling-a-test}",
         messageModel = MessageModel.CLUSTERING,//负载均衡模式
         consumeThreadMax = 1//消费者最大线程数，每次只消费一个
 )
 public class BuildSceneListener implements RocketMQListener<String> {
 
-    @Value("${rocketmq.consumer.build-scene-group}")
+    @Value("${rocketmq.consumer.build-scene-group-test}")
     private String consumerGroup;
 
-    @Value("${rocketmq.build-scene.topicName.topic-modeling-a}")
+    @Value("${rocketmq.build-scene.topicName.topic-modeling-a-test}")
     private String topicName;
 
-    @Value("${rocketmq.build-scene-result.topicName.topic-modeling-a-dt}")
+    @Value("${rocketmq.build-scene.topicName.topic-modeling-a-dt-test}")
     private String topicNameDt;
 
-    @Value("${rocketmq.build-scene-result.topicName.topic-modeling-a}")
+    @Value("${rocketmq.build-scene-result.topicName.topic-modeling-a-test}")
     private String buildSceneResultTopic;
 
     @Autowired

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildScenePreMQListener.java

@@ -98,7 +98,7 @@ public class BuildScenePreMQListener implements RocketMQListener<String> {
     IBuildScenePreService buildScenePreService;
     @Autowired
     private RocketMQProducer producer;
-    @Value("${rocketmq.build-scene.topicName.topic-modeling-a}")
+    @Value("${rocketmq.build-scene.topicName.topic-modeling-a-test}")
     private String topicName;
 
 

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildSceneResultMQListener.java

@@ -64,10 +64,10 @@ import org.springframework.transaction.annotation.Transactional;
 )
 public class BuildSceneResultMQListener implements RocketMQListener<String> {
 
-    @Value("${rocketmq.consumer.build-scene-result-group}")
+    @Value("${rocketmq.consumer.build-scene-result-group-test}")
     private String consumerGroup;
 
-    @Value("${rocketmq.build-scene-result.topicName.topic-modeling-a}")
+    @Value("${rocketmq.build-scene-result.topicName.topic-modeling-a-test}")
     private String buildSceneResultTopic;
 
     @Value("${main.url}")