From e16ac98e0d1049d18c508799d64f11d942c74920 Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Sun, 27 Apr 2025 14:32:57 +0800 Subject: [PATCH] refactor(votesActivity): 修改自主报名字段名称 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 64 ++++++++++++++++++++++++++++++++ 1 files changed, 64 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..af0f67a 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,68 @@ 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()); + } + + + @Bean + public DirectExchange activityOrderCheckExchange() { + return new DirectExchange(RabbitQueueEnum.ACTIVITY_ORDER_ITEM_CHECK.getExchange()); + } + + @Bean + public Queue activityOrderCheckQueue() { + return new Queue(QueueConstants.ACTIVITY_ORDER_ITEM_CHECK); + } + + @Bean + public Binding activityOrderCheckBind() { + return BindingBuilder.bind(activityOrderCheckQueue()).to(activityOrderCheckExchange()).with(RabbitQueueEnum.ACTIVITY_ORDER_ITEM_CHECK.getRoute()); + } + } -- Gitblit v1.9.1