From 5eed9d5001fb6e8a7af4e16f1bf0c43cafadf403 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 15 Dec 2023 10:49:27 +0800 Subject: [PATCH] 微信小程序配置 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 34 ++++++++++++++++++++++++++++++++++ 1 files changed, 34 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java index b4b5144..062b8d8 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -213,4 +213,38 @@ } //强制卖出 end + //卖单用户确认 start + @Bean + public DirectExchange fcmOrderSellInsureExchange() { + return new DirectExchange(RabbitQueueEnum.FCMPAY_FCM_ORDER_SELL_INSURE.getExchange()); + } + + @Bean + public Queue fcmOrderSellInsureQueue() { + return new Queue(RabbitQueueEnum.FCMPAY_FCM_ORDER_SELL_INSURE.getQueue()); + } + + @Bean + public Binding fcmOrderSellInsureBind() { + return BindingBuilder.bind(fcmOrderSellInsureQueue()).to(fcmOrderSellInsureExchange()).with(RabbitQueueEnum.FCMPAY_FCM_ORDER_SELL_INSURE.getRoute()); + } + //卖单用户确认 end + + //买单取消 start + @Bean + public DirectExchange fcmOrderBuyCancelExchange() { + return new DirectExchange(RabbitQueueEnum.FCMPAY_FCM_ORDER_BUY_CANCEL.getExchange()); + } + + @Bean + public Queue fcmOrderBuyCancelQueue() { + return new Queue(RabbitQueueEnum.FCMPAY_FCM_ORDER_BUY_CANCEL.getQueue()); + } + + @Bean + public Binding fcmOrderBuyCancelBind() { + return BindingBuilder.bind(fcmOrderBuyCancelQueue()).to(fcmOrderBuyCancelExchange()).with(RabbitQueueEnum.FCMPAY_FCM_ORDER_BUY_CANCEL.getRoute()); + } + //买单取消 end + } -- Gitblit v1.9.1