库存加锁 回调修改

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

@@ -114,7 +114,37 @@ public class ConsumerProcessor {
             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) {
+    public void consumerOrderCreate1(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CREATE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+
+    // 订单创建
+    @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 consumerOrderCreate2(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CREATE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+
+    // 订单创建
+    @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 consumerOrderCreate3(Message msg, Channel channel) {
+        log.info("===   CONSUMER_ORDER_CREATE   ===");
+        this.consumerSqlDaoHandler(msg, channel);
+    }
+
+    // 订单创建
+    @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 consumerOrderCreate4(Message msg, Channel channel) {
         log.info("===   CONSUMER_ORDER_CREATE   ===");
         this.consumerSqlDaoHandler(msg, channel);
     }