From 1e4cab335b1cb68ad3438e522ea410c2d2e753ed Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Tue, 07 Sep 2021 14:54:16 +0800
Subject: [PATCH] data_move
---
src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java | 15 +++++++++++++++
1 files changed, 15 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 d43efca..084d625 100644
--- a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
+++ b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
@@ -134,6 +134,10 @@
public static final String QUEUE_TRC20_BLOCK = "QUEUE_TRC20_BLOCK";
public static final String ROUTING_TRC20_BLOCK = "ROUTING_TRC20_BLOCK";
+
+ public static final String QUEUE_ORDER_RETURN = "QUEUE_ORDER_RETURN";
+ public static final String ROUTING_ORDER_RETURN = "ROUTING_ORDER_RETURN";
+
@Resource
private ConnectionFactory connectionFactory;
@@ -199,6 +203,17 @@
}
@Bean
+ public Queue orderReturnQueue() {
+ return new Queue(QUEUE_ORDER_RETURN);
+ }
+
+ @Bean
+ public Binding orderReturnBinding() {
+ return BindingBuilder.bind(orderReturnQueue()).to(defaultExchange()).with(ROUTING_ORDER_RETURN);
+ }
+
+
+ @Bean
public Queue trc20Queue() {
return new Queue(QUEUE_TRC20_BLOCK);
}
--
Gitblit v1.9.1