From eafe68cf77bee466b7cea122784f784e694fef53 Mon Sep 17 00:00:00 2001
From: Hentua <wangdoubleone@gmail.com>
Date: Thu, 15 Jun 2023 09:01:41 +0800
Subject: [PATCH] “1
---
src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 20 ++++++++++++++++++++
1 files changed, 20 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 e1f7784..232d796 100644
--- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
+++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
@@ -185,4 +185,24 @@
return BindingBuilder.bind(orderBonusQueue()).to(orderBonusExchange()).with(RabbitQueueEnum.ORDER_BONUS.getRoute());
}
//订单分红 end
+
+
+ /**
+ * 矩阵节点
+ * @return
+ */
+ @Bean
+ public DirectExchange matrixTreeExchange() {
+ return new DirectExchange(RabbitQueueEnum.MATRIX_TREE.getExchange());
+ }
+
+ @Bean
+ public Queue matrixTreeQueue() {
+ return new Queue(QueueConstants.MATRIX_TREE);
+ }
+
+ @Bean
+ public Binding matrixTreeBind() {
+ return BindingBuilder.bind(matrixTreeQueue()).to(matrixTreeExchange()).with(RabbitQueueEnum.MATRIX_TREE.getRoute());
+ }
}
--
Gitblit v1.9.1