From 8ee5e148287a2b7105ab2baaaec2edc83af6ec36 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 14 Jun 2024 12:52:09 +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 8b6fea9..898fadf 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java +++ b/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java @@ -139,4 +139,23 @@ return BindingBuilder.bind(nodePerkQueue()).to(nodePerkExchange()).with(QueueEnum.TFC_NODE_PERK.getRoute()); } // === 发送节点奖励 end === + + + + // === 发送复投 start === + @Bean + public DirectExchange nodeAgainExchange() { + return new DirectExchange(QueueEnum.TFC_NODE_AGAIN.getExchange()); + } + + @Bean + public Queue nodeAgainQueue() { + return new Queue(QueueEnum.TFC_NODE_AGAIN.getQueue()); + } + + @Bean + public Binding nodeAgainBind() { + return BindingBuilder.bind(nodeAgainQueue()).to(nodeAgainExchange()).with(QueueEnum.TFC_NODE_AGAIN.getRoute()); + } + // === 发送复投 end === } -- Gitblit v1.9.1