From 7c0a76b5b622ac4b7344f14228cf5f026bec9cde Mon Sep 17 00:00:00 2001 From: Hentua <wangdoubleone@gmail.com> Date: Sat, 16 Sep 2023 00:17:20 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 16 ++++++++++++++++ 1 files changed, 16 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..32b3b5e 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,20 @@ return BindingBuilder.bind(orderReturnMoneyQueue()).to(orderReturnMoneyExchange()).with(RabbitQueueEnum.ORDER_RETURN_MONEY.getRoute()); } + + @Bean + public DirectExchange orderCouponExchange() { + return new DirectExchange(RabbitQueueEnum.ORDER_COUPON.getExchange()); + } + + @Bean + public Queue orderCouponQueue() { + return new Queue(QueueConstants.ORDER_COUPON); + } + + @Bean + public Binding orderCouponBind() { + return BindingBuilder.bind(orderCouponQueue()).to(orderCouponExchange()).with(RabbitQueueEnum.ORDER_COUPON.getRoute()); + } + } -- Gitblit v1.9.1