From 76e42bfdf66fbd49e4ed3173236b2f4b352685b2 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 07 Jun 2024 16:43:11 +0800 Subject: [PATCH] 将监听充值新建一个项目 --- src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java | 19 +++++++++++++++++++ 1 files changed, 19 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java b/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java index 1085672..cb11d30 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java +++ b/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java @@ -82,4 +82,23 @@ return BindingBuilder.bind(tfcNewPriceQueue()).to(tfcNewPriceExchange()).with(QueueEnum.TFC_NEW_PRICE.getRoute()); } // === tfc最新价 end === + + + + // === 手续费分发 start === + @Bean + public DirectExchange feeDistributeExchange() { + return new DirectExchange(QueueEnum.DISTRIB_PROFIT.getExchange()); + } + + @Bean + public Queue feeDistributeQueue() { + return new Queue(QueueEnum.DISTRIB_PROFIT.getQueue()); + } + + @Bean + public Binding feeDistributeBind() { + return BindingBuilder.bind(feeDistributeQueue()).to(feeDistributeExchange()).with(QueueEnum.DISTRIB_PROFIT.getRoute()); + } + // === 手续费分发 end === } -- Gitblit v1.9.1