配置修改

src/main/java/com/emato/file/tunnel/config/RabbitMQConfig.java

@@ -79,6 +79,10 @@ public class RabbitMQConfig {
         SimpleMessageListenerContainer listenerContainer = (SimpleMessageListenerContainer) rabbitListenerContainerFactory.createListenerContainer();
 
         // 支持621、623、625、311的上报
+        // 电子订单（311）和621、623、625不在一台报文机上
+        // 所以上报电子订单需要注释其他的队列
+        // 上报621、623、625需要注释311队列
+        // TODO 改为在配置文件中配置
         listenerContainer.setQueueNames(
                 rabbitMQProperties.getQ_normal_csp_to_tunnel_report_311(),
                 rabbitMQProperties.getQ_normal_csp_to_tunnel_report_621(),
@@ -146,7 +150,10 @@ public class RabbitMQConfig {
 
     @Bean
     public Binding ceb621ReceiptBinding () {
-        return BindingBuilder.bind(ceb621ReceiptQueue()).to(receiptDirectExchange()).with(rabbitMQProperties.getK_normal_tunnel_to_csp_receipt_621());
+        return BindingBuilder
+                .bind(ceb621ReceiptQueue())
+                .to(receiptDirectExchange())
+                .with(rabbitMQProperties.getK_normal_tunnel_to_csp_receipt_621());
     }
 
     @Bean
@@ -156,7 +163,10 @@ public class RabbitMQConfig {
 
     @Bean
     public Binding ceb311ReceiptBinding () {
-        return BindingBuilder.bind(ceb311ReceiptQueue()).to(receiptDirectExchange()).with(rabbitMQProperties.getK_normal_tunnel_to_csp_receipt_311());
+        return BindingBuilder
+                .bind(ceb311ReceiptQueue())
+                .to(receiptDirectExchange())
+                .with(rabbitMQProperties.getK_normal_tunnel_to_csp_receipt_311());
     }
     /* **************************************** 回执队列相关配置完毕 ******************************************* */
 
@@ -184,7 +194,10 @@ public class RabbitMQConfig {
 
     @Bean
     public Binding ceb621ReportBinding () {
-        return BindingBuilder.bind(ceb621ReportQueue()).to(reportDirectExchange()).with(rabbitMQProperties.getK_normal_csp_to_tunnel_report_621());
+        return BindingBuilder
+                .bind(ceb621ReportQueue())
+                .to(reportDirectExchange())
+                .with(rabbitMQProperties.getK_normal_csp_to_tunnel_report_621());
     }
 
     @Bean
@@ -194,7 +207,10 @@ public class RabbitMQConfig {
 
     @Bean
     public Binding ceb311ReportBinding () {
-        return BindingBuilder.bind(ceb621ReportQueue()).to(reportDirectExchange()).with(rabbitMQProperties.getK_normal_csp_to_tunnel_report_311());
+        return BindingBuilder
+                .bind(ceb311ReportQueue())
+                .to(reportDirectExchange())
+                .with(rabbitMQProperties.getK_normal_csp_to_tunnel_report_311());
     }
 
     /* **************************************** 上报报文相关配置完成 ******************************************* */