From 529ad9dd8d1876b57e852bc45b602ba3ccc8df2a Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Wed, 10 Apr 2024 17:19:08 +0800 Subject: [PATCH] 公告-首页公告调整 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 48 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 48 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..5c4f242 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,52 @@ 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()); + } + + + @Bean + public DirectExchange getScoreMsgExchange() { + return new DirectExchange(RabbitQueueEnum.GET_SCORE_MSG.getExchange()); + } + + @Bean + public Queue getScoreMsgQueue() { + return new Queue(QueueConstants.GET_SCORE_MSG); + } + + @Bean + public Binding getScoreMsgBind() { + return BindingBuilder.bind(getScoreMsgQueue()).to(getScoreMsgExchange()).with(RabbitQueueEnum.GET_SCORE_MSG.getRoute()); + } + + + @Bean + public DirectExchange vipLevelUp() { + return new DirectExchange(RabbitQueueEnum.VIP_LEVEL_UP.getExchange()); + } + + @Bean + public Queue vipLevelUpQueue() { + return new Queue(QueueConstants.VIP_LEVEL_UP); + } + + @Bean + public Binding vipLevelUpBind() { + return BindingBuilder.bind(vipLevelUpQueue()).to(vipLevelUp()).with(RabbitQueueEnum.VIP_LEVEL_UP.getRoute()); + } + } -- Gitblit v1.9.1