From f0de669a7d37d15f841952e41834ecca07aa1fc5 Mon Sep 17 00:00:00 2001
From: zainali5120 <512061637@qq.com>
Date: Fri, 09 Oct 2020 17:06:40 +0800
Subject: [PATCH] 优化usdt同步
---
src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java | 48 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 48 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
index 1389b69..501d615 100644
--- a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
+++ b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
@@ -29,6 +29,14 @@
public static final String EXCHANGE_A = "biue-exchange-A";
+
+ public static final String EXCHANGE_USDT_UPDATE = "exchange_usdt_update";
+
+ public static final String QUEUE_USDT_UPDATE = "queue_usdt_update";
+
+ public static final String ROUTING_KEY_USDT_UPDATE = "routing_key_usdt_update";
+
+
/**
* 撮合交易
*/
@@ -89,6 +97,13 @@
// 交易订单处理
public static final String ROUTINGKEY_HANDLE_TRADE = "ROUTINGKEY_HANDLE_TRADE";
+ public static final String EXCHANGE_ROC = "roc-transfer";
+
+ public static final String QUEUE_ROC= "roc-queue";
+
+ public static final String ROUTING_KEY_ROC = "roc-transfer-routingKey";
+
+
@Resource
private ConnectionFactory connectionFactory;
@@ -121,6 +136,23 @@
@Bean
public Binding binding() {
return BindingBuilder.bind(testQueue()).to(defaultExchange()).with(ROUTING_KEY_TEST);
+ }
+
+
+ @Bean
+ public DirectExchange usdtUpdateExchange() {
+ return new DirectExchange(EXCHANGE_USDT_UPDATE);
+ }
+
+
+ @Bean
+ public Queue usdtUpdateQueue() {
+ return new Queue(QUEUE_USDT_UPDATE, true);
+ }
+
+ @Bean
+ public Binding usdtUpdatebinding() {
+ return BindingBuilder.bind(usdtUpdateQueue()).to(usdtUpdateExchange()).with(ROUTING_KEY_USDT_UPDATE);
}
@@ -351,4 +383,20 @@
return BindingBuilder.bind(queueHandleTrade()).to(matchTradeExchange()).with(RabbitMqConfig.ROUTINGKEY_HANDLE_TRADE);
}
+ @Bean
+ public DirectExchange rocExchange() {
+ return new DirectExchange(EXCHANGE_ROC);
+ }
+
+
+ @Bean
+ public Queue rocQueue() {
+ return new Queue(QUEUE_ROC, true);
+ }
+
+ @Bean
+ public Binding bindingRoc() {
+ return BindingBuilder.bind(rocQueue()).to(rocExchange()).with(ROUTING_KEY_ROC);
+ }
+
}
--
Gitblit v1.9.1