From b59cea31dc3f47a59027fb370f95a14910210cef Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 20 May 2021 19:27:16 +0800
Subject: [PATCH] Merge branch 'yunding' of http://120.27.238.55:7000/r/exchange into yunding
---
src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java | 51 +++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 49 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
index 5a0308f..a76a891 100644
--- a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
+++ b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
@@ -42,6 +42,13 @@
public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address";
+ 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";
+
/**
* 撮合交易
@@ -83,6 +90,11 @@
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";
@@ -137,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);
}
@@ -149,7 +186,7 @@
@Bean
public DirectExchange usdtUpdateExchange() {
- return new DirectExchange(EXCHANGE_USDT_UPDATE);
+ return new DirectExchange(EXCHANGE_XCH);
}
@@ -165,7 +202,7 @@
@Bean
public DirectExchange usdtAddressExchange() {
- return new DirectExchange(EXCHANGE_USDT_ADDRESS);
+ return new DirectExchange(EXCHANGE_XCH);
}
@@ -305,6 +342,16 @@
}
@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);
}
--
Gitblit v1.9.1