From 3cfc2e7d4206f332da8af1c161725fc8a02df1e3 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 07 Jun 2023 10:11:50 +0800
Subject: [PATCH] twoCoin项目修改
---
src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java | 18 ++++++++++++++++++
1 files changed, 18 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 3781345..b5126f1 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
@@ -340,4 +340,22 @@
return BindingBuilder.bind(antKLineQueue()).to(antKLineExchange()).with(QueueEnum.ANT_K_LINE.getRoute());
}
// === A k线数据 end ===
+
+
+ // === A k线数据 start ===
+ @Bean
+ public DirectExchange antKLineABExchange() {
+ return new DirectExchange(QueueEnum.ANT_K_LINE_AB.getExchange());
+ }
+
+ @Bean
+ public Queue antKLineABQueue() {
+ return new Queue(QueueEnum.ANT_K_LINE_AB.getQueue());
+ }
+
+ @Bean
+ public Binding antKLineABBind() {
+ return BindingBuilder.bind(antKLineABQueue()).to(antKLineABExchange()).with(QueueEnum.ANT_K_LINE_AB.getRoute());
+ }
+ // === A k线数据 end ===
}
--
Gitblit v1.9.1