生产计划-功能优化 5.13

jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/JeecgSystemApplication.java

@@ -77,24 +77,24 @@ public class JeecgSystemApplication extends SpringBootServletInitializer {
     }
 
 
-//    @Autowired
+    @Autowired
-//    private Environment environment;
+    private Environment environment;
-//
+
-//    //创建队列
+    //创建队列
-//    @Bean
+    @Bean
-//    public Queue queue() {
+    public Queue queue() {
-//        return new Queue(environment.getProperty("mq.pay.queue.order"));
+        return new Queue(environment.getProperty("mq.pay.queue.order"));
-//    }
+    }
-//
+
-//    //创建交换机
+    //创建交换机
-//    @Bean
+    @Bean
-//    public DirectExchange directExchange() {
+    public DirectExchange directExchange() {
-//        return new DirectExchange(environment.getProperty("mq.pay.exchange.order"));
+        return new DirectExchange(environment.getProperty("mq.pay.exchange.order"));
-//    }
+    }
-//
+
-//    //将队列与交换机进行绑定
+    //将队列与交换机进行绑定
-//    @Bean
+    @Bean
-//    public Binding binding() {
+    public Binding binding() {
-//        return BindingBuilder.bind(queue()).to(directExchange()).with(environment.getProperty("mq.pay.routing.order"));
+        return BindingBuilder.bind(queue()).to(directExchange()).with(environment.getProperty("mq.pay.routing.order"));
-//    }
+    }
 }