From c92f4c5a78a77331c65059a635191b35752346bf Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Tue, 20 May 2025 17:58:20 +0800 Subject: [PATCH] refactor(mall): 重构 getCouponAmountMap 方法 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 20 +++++++++++++++++++- 1 files changed, 19 insertions(+), 1 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 af0f67a..89f0eaf 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -171,6 +171,24 @@ } + + + @Bean + public DirectExchange saleLevelUp() { + return new DirectExchange(RabbitQueueEnum.SALE_LEVEL_UP.getExchange()); + } + + @Bean + public Queue saleLevelUpQueue() { + return new Queue(RabbitQueueEnum.SALE_LEVEL_UP.getQueue()); + } + + @Bean + public Binding saleLevelUpBind() { + return BindingBuilder.bind(saleLevelUpQueue()).to(saleLevelUp()).with(RabbitQueueEnum.SALE_LEVEL_UP.getRoute()); + } + + @Bean public DirectExchange activityOrderCheckExchange() { return new DirectExchange(RabbitQueueEnum.ACTIVITY_ORDER_ITEM_CHECK.getExchange()); @@ -178,7 +196,7 @@ @Bean public Queue activityOrderCheckQueue() { - return new Queue(QueueConstants.ACTIVITY_ORDER_ITEM_CHECK); + return new Queue(RabbitQueueEnum.ACTIVITY_ORDER_ITEM_CHECK.getQueue()); } @Bean -- Gitblit v1.9.1