线路预警

performance-web/src/main/java/com/clx/performance/config/RabbitLineWarnConfig.java

@@ -32,11 +32,13 @@ public class RabbitLineWarnConfig {
         params.put("x-max-length", 5000000);
         params.put("x-dead-letter-exchange", RabbitKeyLineWarnConstants.DEFAULT_EXCHANGE);
         params.put("x-dead-letter-routing-key", RabbitKeyLineWarnConstants.DEFAULT_DEAD_ROUTING_KEY);
-        return new Queue(RabbitKeyLineWarnConstants.DEFAULT_DELAY_QUEUE, true, false, false, params);
+        return new Queue(RabbitKeyLineWarnConstants.DEFAULT_DELAY_QUEUE,
+                true, false, false, params);
     }
     @Bean
     public Binding lineWarnDefaultDelayQueueBinding() {
-        return BindingBuilder.bind(lineWarnDefaultDelayQueue()).to(lineWarnDefaultExchange()).with(RabbitKeyLineWarnConstants.DEFAULT_DELAY_ROUTING_KEY);
+        return BindingBuilder.bind(lineWarnDefaultDelayQueue()).to(lineWarnDefaultExchange())
+                .with(RabbitKeyLineWarnConstants.DEFAULT_DELAY_ROUTING_KEY);
     }
 
     @Bean
@@ -45,7 +47,8 @@ public class RabbitLineWarnConfig {
     }
     @Bean
     public Binding lineWarnDefaultDeadQueueBinding() {
-        return BindingBuilder.bind(lineWarnDefaultDeadQueue()).to(lineWarnDefaultExchange()).with(RabbitKeyLineWarnConstants.DEFAULT_DEAD_ROUTING_KEY);
+        return BindingBuilder.bind(lineWarnDefaultDeadQueue()).to(lineWarnDefaultExchange())
+                .with(RabbitKeyLineWarnConstants.DEFAULT_DEAD_ROUTING_KEY);
     }
 
 
@@ -58,7 +61,8 @@ public class RabbitLineWarnConfig {
     }
     @Bean
     public Binding lineWarnChildAddQueueBinding() {
-        return BindingBuilder.bind(lineWarnChildAddQueue()).to(lineWarnDefaultExchange()).with(RabbitKeyLineWarnConstants.ORDER_GOODS_ADD_ROUTING_KEY);
+        return BindingBuilder.bind(lineWarnChildAddQueue()).to(lineWarnDefaultExchange())
+                .with(RabbitKeyLineWarnConstants.ORDER_GOODS_ADD_ROUTING_KEY);
     }
 
     /**
@@ -70,7 +74,8 @@ public class RabbitLineWarnConfig {
     }
     @Bean
     public Binding lineWarnQueueBinding() {
-        return BindingBuilder.bind(lineWarnQueue()).to(lineWarnDefaultExchange()).with(RabbitKeyLineWarnConstants.LINE_WARN_ROUTING_KEY);
+        return BindingBuilder.bind(lineWarnQueue()).to(lineWarnDefaultExchange())
+                .with(RabbitKeyLineWarnConstants.LINE_WARN_ROUTING_KEY);
     }
     /**
      * 线路预警通知
@@ -81,7 +86,8 @@ public class RabbitLineWarnConfig {
     }
     @Bean
     public Binding lineWarnNoticeQueueBinding() {
-        return BindingBuilder.bind(lineWarnNoticeQueue()).to(lineWarnDefaultExchange()).with(RabbitKeyLineWarnConstants.LINE_WARN_NOTICE_ROUTING_KEY);
+        return BindingBuilder.bind(lineWarnNoticeQueue()).to(lineWarnDefaultExchange())
+                .with(RabbitKeyLineWarnConstants.LINE_WARN_NOTICE_ROUTING_KEY);
     }
 
     /**
@@ -93,7 +99,21 @@ public class RabbitLineWarnConfig {
     }
     @Bean
     public Binding lineWarnLineReportQueueBinding() {
-        return BindingBuilder.bind(lineWarnNoticeQueue()).to(lineWarnDefaultExchange()).with(RabbitKeyLineWarnConstants.LINE_WARN_LINE_REPORT_ROUTING_KEY);
+        return BindingBuilder.bind(lineWarnNoticeQueue()).to(lineWarnDefaultExchange())
+                .with(RabbitKeyLineWarnConstants.LINE_WARN_LINE_REPORT_ROUTING_KEY);
+    }
+
+    /**
+     * 异常运单
+     */
+    @Bean
+    public Queue lineWarnOrderChildWarnQueue() {
+        return new Queue(RabbitKeyLineWarnConstants.LINE_WARN_ORDER_CHILD_WARN_QUEUE);
+    }
+    @Bean
+    public Binding lineWarnOrderChildWarnQueueBinding() {
+        return BindingBuilder.bind(lineWarnOrderChildWarnQueue()).to(lineWarnDefaultExchange())
+                .with(RabbitKeyLineWarnConstants.LINE_WARN_ORDER_CHILD_WARN_ROUTING_KEY);
     }
 
 }