From 9f335de3384f48c9021f49d44ba8f3925fdb114c Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Fri, 26 May 2023 11:01:49 +0800 Subject: [PATCH] 正式环境 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 42 ++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 42 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 50797b6..7079411 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -122,4 +122,46 @@ return BindingBuilder.bind(orderReturnMoneyQueue()).to(orderReturnMoneyExchange()).with(RabbitQueueEnum.ORDER_RETURN_MONEY.getRoute()); } + /** + * 补贴金额 + * @return + */ + //补贴金额 start + @Bean + public DirectExchange perkMoneyExchange() { + return new DirectExchange(RabbitQueueEnum.PERK_MONEY.getExchange()); + } + + @Bean + public Queue perkMoneyQueue() { + return new Queue(QueueConstants.PERK_MONEY); + } + + @Bean + public Binding perkMoneyBind() { + return BindingBuilder.bind(perkMoneyQueue()).to(perkMoneyExchange()).with(RabbitQueueEnum.PERK_MONEY.getRoute()); + } + //补贴金额 end + + /** + * 强制卖出 + * @return + */ + //强制卖出 start + @Bean + public DirectExchange forceVoucherSaleExchange() { + return new DirectExchange(RabbitQueueEnum.FORCE_VOUCHER_SALE.getExchange()); + } + + @Bean + public Queue forceVoucherSaleQueue() { + return new Queue(QueueConstants.FORCE_VOUCHER_SALE); + } + + @Bean + public Binding forceVoucherSaleBind() { + return BindingBuilder.bind(forceVoucherSaleQueue()).to(forceVoucherSaleExchange()).with(RabbitQueueEnum.FORCE_VOUCHER_SALE.getRoute()); + } + //强制卖出 end + } -- Gitblit v1.9.1