From 11f6a8c911c5ef241f42953976661a249aa8b83e Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 08 Aug 2023 17:18:58 +0800
Subject: [PATCH] 数据修改
---
src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java | 54 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 54 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 b5126f1..da4f966 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
@@ -358,4 +358,58 @@
return BindingBuilder.bind(antKLineABQueue()).to(antKLineABExchange()).with(QueueEnum.ANT_K_LINE_AB.getRoute());
}
// === A k线数据 end ===
+
+
+ // === A k线数据 start ===
+ @Bean
+ public DirectExchange allMemberPerkAvaExchange() {
+ return new DirectExchange(QueueEnum.ALL_MEMBER_PERK_AVA.getExchange());
+ }
+
+ @Bean
+ public Queue allMemberPerkAvaQueue() {
+ return new Queue(QueueEnum.ALL_MEMBER_PERK_AVA.getQueue());
+ }
+
+ @Bean
+ public Binding allMemberPerkAvaBind() {
+ return BindingBuilder.bind(allMemberPerkAvaQueue()).to(allMemberPerkAvaExchange()).with(QueueEnum.ALL_MEMBER_PERK_AVA.getRoute());
+ }
+ // === A k线数据 end ===
+
+
+ // === A 合约铸造ANDAO start ===
+ @Bean
+ public DirectExchange contractAnDaoExchange() {
+ return new DirectExchange(QueueEnum.CONTRACT_AN_DAO.getExchange());
+ }
+
+ @Bean
+ public Queue contractAnDaoQueue() {
+ return new Queue(QueueEnum.CONTRACT_AN_DAO.getQueue());
+ }
+
+ @Bean
+ public Binding contractAnDaoBind() {
+ return BindingBuilder.bind(contractAnDaoQueue()).to(contractAnDaoExchange()).with(QueueEnum.CONTRACT_AN_DAO.getRoute());
+ }
+ // === A 合约铸造ANDAO end ===
+
+
+ // === A 合约铸造ANDAO start ===
+ @Bean
+ public DirectExchange contractAnDaoInExchange() {
+ return new DirectExchange(QueueEnum.ANT_A_CION_IN_CONTRACT.getExchange());
+ }
+
+ @Bean
+ public Queue contractAnDaoInQueue() {
+ return new Queue(QueueEnum.ANT_A_CION_IN_CONTRACT.getQueue());
+ }
+
+ @Bean
+ public Binding contractAnDaoInBind() {
+ return BindingBuilder.bind(contractAnDaoInQueue()).to(contractAnDaoInExchange()).with(QueueEnum.ANT_A_CION_IN_CONTRACT.getRoute());
+ }
+ // === A 合约铸造ANDAO end ===
}
--
Gitblit v1.9.1