From 2d398a2bbd4a210ffd885f0b0b0a0f99edd84707 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Tue, 25 May 2021 10:47:46 +0800
Subject: [PATCH] modify

---
 src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java |   73 +++++++++++++++++++++++++++++++++---
 1 files changed, 67 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
index b8a2da2..e5f74f2 100644
--- a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
+++ b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
@@ -32,15 +32,22 @@
 
     public static final String EXCHANGE_USDT_UPDATE = "exchange_usdt_update";
 
-    public static final String QUEUE_USDT_UPDATE = "queue_usdt_update";
+    public static final String QUEUE_USDT_UPDATE = "queue_usdt_update_xch";
 
-    public static final String ROUTING_KEY_USDT_UPDATE = "routing_key_usdt_update";
+    public static final String ROUTING_KEY_USDT_UPDATE = "routing_key_usdt_update_xch";
 
     public static final String EXCHANGE_USDT_ADDRESS = "exchange_usdt_address";
 
-    public static final String QUEUE_USDT_ADDRESS= "queue_usdt_address";
+    public static final String QUEUE_USDT_ADDRESS= "queue_usdt_address_xch";
 
-    public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address";
+    public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address_xch";
+
+    public static final String QUEUE_XCH_USDT_PRIFIT = "QUEUE_XCH_USDT_PRIFIT";
+    public static final String ROUTING_KEE_XCH_USDT_PRIFIT = "ROUTING_KEE_XCH_USDT_PRIFIT";
+    public static final String EXCHANGE_XCH = "EXCHANGE_XCH";
+
+    public static final String QUEUE_XCH_AUTO_AGENT = "QUEUE_XCH_AUTO_AGENT";
+    public static final String ROUTING_KEY_XCH_AUTO_AGENT = "ROUTING_KEY_XCH_AUTO_AGENT";
 
 
     /**
@@ -79,6 +86,15 @@
     // 全仓价格操作
     public static final String QUEUE_WHOLE_PRICE = "QUEUE_WHOLE_PRCE";
 
+    // 跟单下单
+    public static final String QUEUE_FOLLOW_ORDER = "QUEUE_FOLLOW_ORDER";
+
+    public static final String ROUTINGKEY_FOLLOW_ORDER = "ROUTINGKEY_FOLLOW_ORDER";
+
+    // 跟单调整保证金
+    public static final String QUEUE_FOLLOW_CHANGE_BOND = "QUEUE_FOLLOW_CHANGE_BOND";
+
+    public static final String ROUTINGKEY_FOLLOW_CHANGE_BOND = "ROUTINGKEY_FOLLOW_CHANGE_BOND";
 
     // 开多止盈路由键
     public static final String ROUTINGKEY_MOREPRO = "ROUTINGKEY_MOREPRO";
@@ -133,6 +149,31 @@
     }
 
     @Bean
+    public DirectExchange xchExchange() {
+        return new DirectExchange(EXCHANGE_XCH);
+    }
+
+    @Bean
+    public Queue xchUsdtProfitQueue() {
+        return new Queue(QUEUE_XCH_USDT_PRIFIT, true);
+    }
+
+    @Bean
+    public Binding xchUsdtProfitBinding() {
+        return BindingBuilder.bind(xchUsdtProfitQueue()).to(xchExchange()).with(ROUTING_KEE_XCH_USDT_PRIFIT);
+    }
+
+    @Bean
+    public Queue xchAutoAgentQueue() {
+        return new Queue(QUEUE_XCH_AUTO_AGENT, true);
+    }
+
+    @Bean
+    public Binding xchAutoAgentBinding() {
+        return BindingBuilder.bind(xchAutoAgentQueue()).to(xchExchange()).with(ROUTING_KEY_XCH_AUTO_AGENT);
+    }
+
+    @Bean
     public Queue testQueue() {
         return new Queue(QUEUE_TEST, true);
     }
@@ -145,7 +186,7 @@
 
    @Bean
     public DirectExchange usdtUpdateExchange() {
-        return new DirectExchange(EXCHANGE_USDT_UPDATE);
+        return new DirectExchange(EXCHANGE_XCH);
     }
 
 
@@ -161,7 +202,7 @@
 
     @Bean
     public DirectExchange usdtAddressExchange() {
-        return new DirectExchange(EXCHANGE_USDT_ADDRESS);
+        return new DirectExchange(EXCHANGE_XCH);
     }
 
 
@@ -295,6 +336,26 @@
         return new Queue(QUEUE_WHOLE_BOMB, true);
     }
 
+    @Bean
+    public Queue queueFollowOrder() {
+        return new Queue(QUEUE_FOLLOW_ORDER, true);
+    }
+
+    @Bean
+    public Queue queueFollowChangeBond() {
+        return new Queue(QUEUE_FOLLOW_CHANGE_BOND, true);
+    }
+
+    @Bean
+    public Binding bindingFollowChangeBond() {
+        return BindingBuilder.bind(queueFollowChangeBond()).to(orderExchange()).with(ROUTINGKEY_FOLLOW_CHANGE_BOND);
+    }
+
+    @Bean
+    public Binding bindingFollowOrder() {
+        return BindingBuilder.bind(queueFollowOrder()).to(orderExchange()).with(RabbitMqConfig.ROUTINGKEY_FOLLOW_ORDER);
+    }
+
 
     @Bean
     public Binding bindingWholePrice() {

--
Gitblit v1.9.1