فهرست منبع

修改V3场景构建逻辑

tianboguang 2 سال پیش
والد
کامیت
2a31cd9a47
1فایلهای تغییر یافته به همراه4 افزوده شده و 4 حذف شده
  1. 4 4
      src/main/java/com/fdkankan/contro/mq/listener/BuildV3SceneListener.java

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

@@ -14,9 +14,9 @@ import org.springframework.stereotype.Component;
 @Component
 public class BuildV3SceneListener extends AbstrackBuildSceneListener {
 
-    @Value("${queue.modeling.modeling-pre}")
+    @Value("${queue.modeling.v3.modeling-pre}")
     private String queueModelingPre;
-    @Value("${queue.modeling.modeling-post}")
+    @Value("${queue.modeling.v3.modeling-post}")
     private String queueModelingPost;
 
     @Autowired
@@ -29,7 +29,7 @@ public class BuildV3SceneListener extends AbstrackBuildSceneListener {
      * @throws Exception
      */
     @RabbitListener(
-            queuesToDeclare = @Queue("${queue.modeling.modeling-pre}"),
+            queuesToDeclare = @Queue("${queue.modeling.v3.modeling-pre}"),
             concurrency = "${maxThread.modeling.modeling-pre}"
     )
     public void buildScenePreHandler(Channel channel, Message message) throws Exception {
@@ -43,7 +43,7 @@ public class BuildV3SceneListener extends AbstrackBuildSceneListener {
      * @throws Exception
      */
     @RabbitListener(
-            queuesToDeclare = @Queue("${queue.modeling.modeling-post}"),
+            queuesToDeclare = @Queue("${queue.modeling.v3.modeling-post}"),
             concurrency = "${maxThread.modeling.modeling-post}"
     )
     public void buildScenePostHandler(Channel channel, Message message) throws Exception {