回滚拆分预览队列,

sxz-core/src/main/java/com/fdkk/sxz/other/listener/RunBuild.java

@@ -113,6 +113,13 @@ public class RunBuild {
         }
     }
 
+    //@RabbitHandler
+    //@RabbitListener(queues = TopicRabbitConfig.MODEL_CREAT_THUM)
+    //public void modelCreatThumBiz(String str) {
+    //    RunBuild.log.info("模型：" + str + ",开始生成封面图");
+    //    modelCreatThum(str);
+    //}
+
     @RabbitHandler
     @RabbitListener(queues = TopicRabbitConfig.MODEL)
     public void model(String str) {

sxz-core/src/main/java/com/fdkk/sxz/other/mq/TopicRabbitConfig.java

@@ -23,25 +23,28 @@ public class TopicRabbitConfig {
 //
 //    public final static String TOPICE = "topicExchangeCopy";
 
-    public final static String CHANGE = "topic.chang.dev";
+    public final static String CHANGE = "topic.chang";
     //灯光预览
-    public final static String LIGHT = "topic.light.dev";
+    public final static String LIGHT = "topic.light";
 
-    public final static String MODEL = "topic.model.dev";
+    ////图片渲染
+    //public final static String MODEL_CREAT_THUM = "topic.modelCreatThum";
 
-    public final static String MODEL_BIZ = "topic.modelBiz.dev";
+    public final static String MODEL = "topic.model";
+
+    public final static String MODEL_BIZ = "topic.modelBiz";
 
     //"更新模型库，syncmodel
-    public final static String SYNCMODEL = "topic.syncmodel.dev";
+    public final static String SYNCMODEL = "topic.syncmodel";
 
     //处理
-    public final static String MVIEW = "delay.mview.dev";
+    public final static String MVIEW = "delay.mview";
 
-    public final static String TOPICE = "topicExchange.dev";
+    public final static String TOPICE = "topicExchange";
     /**
      * 延迟消息交换机
      */
-    public final static String DELAY_EXCHANGE = "delay.exchange.dev";
+    public final static String DELAY_EXCHANGE = "delay.exchange";
 
     @Bean
     public CustomExchange delayMessageExchange() {
@@ -81,6 +84,11 @@ public class TopicRabbitConfig {
         return new Queue(TopicRabbitConfig.MVIEW);
     }
 
+    //@Bean
+    //public Queue modelCreatThumQueue() {
+    //    return new Queue(TopicRabbitConfig.MODEL_CREAT_THUM);
+    //}
+
     @Bean
     TopicExchange exchange() {
         return new TopicExchange(TopicRabbitConfig.TOPICE);
@@ -120,4 +128,9 @@ public class TopicRabbitConfig {
         return BindingBuilder.bind(modelBizQueue()).to(exchange()).with(TopicRabbitConfig.MODEL_BIZ);
     }
 
+    //@Bean
+    //Binding bindingExchangeMessage7() {
+    //    return BindingBuilder.bind(modelCreatThumQueue()).to(exchange()).with(TopicRabbitConfig.MODEL_CREAT_THUM);
+    //}
+
 }