Przeglądaj źródła

修改mview生成方式

xiewenjie 3 lat temu
rodzic
commit
6556e00b33

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

@@ -30,7 +30,7 @@ public class TopicRabbitConfig {
     public final static String MODEL = "topic.model";
 
     //处理
-    public final static String MVIEW = "topic.MVIEW";
+    public final static String MVIEW = "topic.mview";
 
     public final static String TOPICE = "topicExchange";
 
@@ -50,7 +50,7 @@ public class TopicRabbitConfig {
     }
 
     @Bean
-    public Queue mVIEWQueue() {
+    public Queue mviewQueue() {
         return new Queue(TopicRabbitConfig.MVIEW);
     }
 
@@ -80,7 +80,7 @@ public class TopicRabbitConfig {
 
     @Bean
     Binding bindingExchangeMessage4() {
-        return BindingBuilder.bind(modelQueue()).to(exchange()).with(TopicRabbitConfig.MVIEW);
+        return BindingBuilder.bind(mviewQueue()).to(exchange()).with(TopicRabbitConfig.MVIEW);
     }
 
 }