Преглед на файлове

修改V3场景构建逻辑

tianboguang преди 2 години
родител
ревизия
daec1cabe0

+ 3 - 3
src/main/java/com/fdkankan/contro/mq/listener/BuildSceneListener.java

@@ -26,7 +26,7 @@ public class BuildSceneListener extends AbstrackBuildSceneListener {
     private String queueModelingPost;
 
     @Autowired
-    private BuildV3SceneServiceImpl buildSceneService;
+    private BuildSceneServiceImpl buildSceneService;
 
     /**
      * 场景计算前置资源准备处理
@@ -35,7 +35,7 @@ public class BuildSceneListener extends AbstrackBuildSceneListener {
      * @throws Exception
      */
     @RabbitListener(
-            queuesToDeclare = @Queue("${queue.modeling.v3.modeling-pre}"),
+            queuesToDeclare = @Queue("${queue.modeling.modeling-pre}"),
             concurrency = "${maxThread.modeling.modeling-pre}"
     )
     public void buildScenePreHandler(Channel channel, Message message) throws Exception {
@@ -49,7 +49,7 @@ public class BuildSceneListener extends AbstrackBuildSceneListener {
      * @throws Exception
      */
     @RabbitListener(
-            queuesToDeclare = @Queue("${queue.modeling.v3.modeling-post}"),
+            queuesToDeclare = @Queue("${queue.modeling.modeling-post}"),
             concurrency = "${maxThread.modeling.modeling-post}"
     )
     public void buildScenePostHandler(Channel channel, Message message) throws Exception {

+ 2 - 1
src/main/java/com/fdkankan/contro/mq/listener/BuildV3SceneListener.java

@@ -1,6 +1,7 @@
 package com.fdkankan.contro.mq.listener;
 
 import com.fdkankan.contro.mq.service.impl.BuildSceneServiceImpl;
+import com.fdkankan.contro.mq.service.impl.BuildV3SceneServiceImpl;
 import com.rabbitmq.client.Channel;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
@@ -20,7 +21,7 @@ public class BuildV3SceneListener extends AbstrackBuildSceneListener {
     private String queueModelingPost;
 
     @Autowired
-    private BuildSceneServiceImpl buildSceneService;
+    private BuildV3SceneServiceImpl buildSceneService;
 
     /**
      * 场景计算前置资源准备处理