From 0d30c93d000413c6eb34f489ef17688ad4175201 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Mon, 29 Apr 2024 18:18:21 +0800 Subject: [PATCH] 55测试环境 --- 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