From 1b44a9a25a51324dba8e8640cb405440f2cf7d48 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 13 May 2021 11:21:32 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java | 19 +++++++++++++++++++
1 files changed, 19 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 216bcca..d61e5e8 100644
--- a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
+++ b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
@@ -42,6 +42,10 @@
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";
+
/**
* 撮合交易
@@ -142,6 +146,21 @@
}
@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 testQueue() {
return new Queue(QUEUE_TEST, true);
}
--
Gitblit v1.9.1