记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 49167727 authored by 张国柄's avatar 张国柄
Browse files
Options

opt;

parent 7679e862
Show whitespace changes
Inline Side-by-side
Showing with 323 additions and 323 deletions
liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerProcessor.java
View file @ 49167727
...@@ -111,32 +111,32 @@ public class ConsumerProcessor { ...@@ -111,32 +111,32 @@ public class ConsumerProcessor {
} }
} }
// // 用户注册 // 用户注册
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UREGISTER, exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UREGISTER,
// value = @Queue(MQConst.QUEUES_SQL_UREGISTER) value = @Queue(MQConst.QUEUES_SQL_UREGISTER)
// )) ))
// public void consumerSqlForURegister(Message msg, Channel channel) { public void consumerSqlForURegister(Message msg, Channel channel) {
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// // 用户信息 // 用户信息
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UCENTER, exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UCENTER,
// value = @Queue(MQConst.QUEUES_SQL_UCENTER) value = @Queue(MQConst.QUEUES_SQL_UCENTER)
// )) ))
// public void consumerSqlForUCenter(Message msg, Channel channel) { public void consumerSqlForUCenter(Message msg, Channel channel) {
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// // 会员购买 // 会员购买
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UMEMBER, exchange = @Exchange(MQConst.EX_LNS_SQL_UCENTER), key = MQConst.RK_SQL_UMEMBER,
// value = @Queue(MQConst.QUEUES_SQL_UMEMBER) value = @Queue(MQConst.QUEUES_SQL_UMEMBER)
// )) ))
// public void consumerSqlForUMember(Message msg, Channel channel) { public void consumerSqlForUMember(Message msg, Channel channel) {
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
// 验票更新 // 验票更新
@RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
...@@ -148,301 +148,301 @@ public class ConsumerProcessor { ...@@ -148,301 +148,301 @@ public class ConsumerProcessor {
} }
// 订单创建 // 订单创建
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate(Message msg, Channel channel) { public void consumerOrderCreate(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate1(Message msg, Channel channel) { public void consumerOrderCreate1(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate2(Message msg, Channel channel) { public void consumerOrderCreate2(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate3(Message msg, Channel channel) { public void consumerOrderCreate3(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate4(Message msg, Channel channel) { public void consumerOrderCreate4(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate5(Message msg, Channel channel) { public void consumerOrderCreate5(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate6(Message msg, Channel channel) { public void consumerOrderCreate6(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate7(Message msg, Channel channel) { public void consumerOrderCreate7(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate8(Message msg, Channel channel) { public void consumerOrderCreate8(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE), key = MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CREATE)
// )) ))
// public void consumerOrderCreate9(Message msg, Channel channel) { public void consumerOrderCreate9(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CREATE ==="); log.info("=== CONSUMER_ORDER_CREATE ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// // 订单再次支付 // 订单再次支付
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_AGAIN), key = MQConst.ROUTING_KEY_SQL_ORDER_AGAIN, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_AGAIN), key = MQConst.ROUTING_KEY_SQL_ORDER_AGAIN,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_AGAIN) value = @Queue(MQConst.QUEUES_SQL_ORDER_AGAIN)
// )) ))
// public void consumerOrderPayAgain(Message msg, Channel channel) { public void consumerOrderPayAgain(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY_AGAIN ==="); log.info("=== CONSUMER_ORDER_PAY_AGAIN ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// // 订单关闭 // 订单关闭
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose(Message msg, Channel channel) { public void consumerOrderClose(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose1(Message msg, Channel channel) { public void consumerOrderClose1(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose2(Message msg, Channel channel) { public void consumerOrderClose2(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose3(Message msg, Channel channel) { public void consumerOrderClose3(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose4(Message msg, Channel channel) { public void consumerOrderClose4(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose5(Message msg, Channel channel) { public void consumerOrderClose5(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose6(Message msg, Channel channel) { public void consumerOrderClose6(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose7(Message msg, Channel channel) { public void consumerOrderClose7(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose8(Message msg, Channel channel) { public void consumerOrderClose8(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE), key = MQConst.ROUTING_KEY_SQL_ORDER_CLOSE,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE) value = @Queue(MQConst.QUEUES_SQL_ORDER_CLOSE)
// )) ))
// public void consumerOrderClose9(Message msg, Channel channel) { public void consumerOrderClose9(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_CLOSE ==="); log.info("=== CONSUMER_ORDER_CLOSE ===");
// this.consumerOperationOrderClose(msg, channel); this.consumerOperationOrderClose(msg, channel);
// } }
//
//
// // 订单支付 // 订单支付
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay(Message msg, Channel channel) { public void consumerOrderPay(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay1(Message msg, Channel channel) { public void consumerOrderPay1(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay2(Message msg, Channel channel) { public void consumerOrderPay2(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay3(Message msg, Channel channel) { public void consumerOrderPay3(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay4(Message msg, Channel channel) { public void consumerOrderPay4(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay5(Message msg, Channel channel) { public void consumerOrderPay5(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay6(Message msg, Channel channel) { public void consumerOrderPay6(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay7(Message msg, Channel channel) { public void consumerOrderPay7(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay8(Message msg, Channel channel) { public void consumerOrderPay8(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
// public void consumerOrderPay9(Message msg, Channel channel) { public void consumerOrderPay9(Message msg, Channel channel) {
// log.info("=== CONSUMER_ORDER_PAY ==="); log.info("=== CONSUMER_ORDER_PAY ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
//
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_PAY), key = MQConst.ROUTING_KEY_SQL_ORDER_PAY,
// value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY) value = @Queue(MQConst.QUEUES_SQL_ORDER_PAY)
// )) ))
//
// // 缺票登记 // 缺票登记
// @RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
// exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_PERFORMANCE_LACK), key = MQConst.ROUTING_KEY_SQL_PERFORMANCE_LACK, exchange = @Exchange(MQConst.EXCHANGES_LIQUIDNET_SQL_PERFORMANCE_LACK), key = MQConst.ROUTING_KEY_SQL_PERFORMANCE_LACK,
// value = @Queue(MQConst.QUEUES_SQL_PERFORMANCE_LACK) value = @Queue(MQConst.QUEUES_SQL_PERFORMANCE_LACK)
// )) ))
// public void consumerPerformanceLack(Message msg, Channel channel) { public void consumerPerformanceLack(Message msg, Channel channel) {
// log.info("=== CONSUMER_PERFORMANCE_LACK ==="); log.info("=== CONSUMER_PERFORMANCE_LACK ===");
// this.consumerSqlDaoHandler(msg, channel); this.consumerSqlDaoHandler(msg, channel);
// } }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment