修改 mq消费

liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerProcessor.java

@@ -58,7 +58,12 @@ public class ConsumerProcessor {
     }
 
     // 订单创建
-    @RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_CREATE)
+//    @RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_CREATE)
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE),
+            key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
+    ))
     public void consumerOrderCreate(Message msg, Channel channel) {
         log.info("===   CONSUMER_ORDER_CREATE   ===");
         SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);
@@ -84,7 +89,12 @@ public class ConsumerProcessor {
     }
 
     //订单再次支付
-    @RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_AGAIN)
+//    @RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_AGAIN)
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_AGAIN),
+            key = MQConst.ROUTING_KEY_SQL_ORDER_AGAIN,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_AGAIN)
+    ))
     public void consumerOrderPayAgain(Message msg, Channel channel) {
         log.info("===   CONSUMER_ORDER_PAY_AGAIN   ===");
         SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);
@@ -110,7 +120,12 @@ public class ConsumerProcessor {
     }
 
     //订单关闭
-    @RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_CLOSE)
+//    @RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_CLOSE)
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE),
+            key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
+    ))
     public void consumerOrderClose(Message msg, Channel channel) {
         log.info("===   CONSUMER_ORDER_CLOSE   ===");
         SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);
@@ -136,7 +151,12 @@ public class ConsumerProcessor {
     }
 
     //订单支付
-    @RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_PAY)
+//    @RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_PAY)
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY),
+            key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
+            value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
+    ))
     public void consumerOrderPay(Message msg, Channel channel) {
         log.info("===   CONSUMER_ORDER_PAY   ===");
         SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);
@@ -162,7 +182,12 @@ public class ConsumerProcessor {
     }
 
     //缺票登记
-    @RabbitListener(queues = MQConst.QUEUES_SQL_PERFORMANCE_LACK)
+//    @RabbitListener(queues = MQConst.QUEUES_SQL_PERFORMANCE_LACK)
+    @RabbitListener(bindings = @QueueBinding(
+            exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_PERFORMANCE_LACK),
+            key = MQConst.ROUTING_KEY_SQL_PERFORMANCE_LACK,
+            value = @Queue(MQConst.QUEUES_SQL_PERFORMANCE_LACK)
+    ))
     public void consumerPerformanceLack(Message msg, Channel channel) {
         log.info("===   CONSUMER_PERFORMANCE_LACK   ===");
         SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);