From 580fe843a333628795d619c5744a8353c44eb8ed Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Thu, 13 Feb 2025 11:31:53 +0800 Subject: [PATCH] feat(mall): 实现充值金额处理和唯一标识生成 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 38 ++++++++++++++++++++++++++++++++++++++ 1 files changed, 38 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 b6ec57a..e6be8e3 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -77,4 +77,42 @@ } // end + + + // start + @Bean + public DirectExchange nodeUpExchange() { + return new DirectExchange(RabbitQueueEnum.RUN_VIP_NODE_UP.getExchange()); + } + + @Bean + public Queue nodeUpQueue() { + return new Queue(RabbitQueueEnum.RUN_VIP_NODE_UP.getQueue()); + } + + @Bean + public Binding nodeUpBind() { + return BindingBuilder.bind(nodeUpQueue()).to(nodeUpExchange()).with(RabbitQueueEnum.RUN_VIP_NODE_UP.getRoute()); + } + // end + + + + // start + @Bean + public DirectExchange chargeExchange() { + return new DirectExchange(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_BALANCE.getExchange()); + } + + @Bean + public Queue chargeQueue() { + return new Queue(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_BALANCE.getQueue()); + } + + @Bean + public Binding chargeBind() { + return BindingBuilder.bind(chargeQueue()).to(chargeExchange()).with(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_BALANCE.getRoute()); + } + // end + } -- Gitblit v1.9.1