From 3af20297ca45b2161bfe51cbd8fd918b293223c2 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 23 Nov 2020 14:55:55 +0800
Subject: [PATCH] 20201123
---
src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java | 22 ++++++++++++++++++++++
1 files changed, 22 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 b9d1449..0a590b2 100644
--- a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
+++ b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java
@@ -121,6 +121,12 @@
public static final String ROUTING_KEY_ROC_ORDER_CANCEL = "roc-order-routingKey-cancel";
+ public static final String EXCHANGE_ROC_ORDER_COMPLETE = "roc-exchange-order-complete";
+
+ public static final String QUEUE_ROC_ORDER_COMPLETE = "roc-order-queue-complete";
+
+ public static final String ROUTING_KEY_ROC_ORDER_COMPLETE = "roc-order-routingKey-complete";
+
@Resource
private ConnectionFactory connectionFactory;
@@ -189,6 +195,22 @@
public Binding bindingCancelOrder() {
return BindingBuilder.bind(ordereCancelQueue()).to(orderCancelExchange()).with(ROUTING_KEY_ROC_ORDER_CANCEL);
}
+ // 交易订单
+ @Bean
+ public DirectExchange orderCompleteExchange() {
+ return new DirectExchange(EXCHANGE_ROC_ORDER_COMPLETE);
+ }
+
+
+ @Bean
+ public Queue ordereCompleteQueue() {
+ return new Queue(QUEUE_ROC_ORDER_COMPLETE, true);
+ }
+
+ @Bean
+ public Binding bindingCompleteOrder() {
+ return BindingBuilder.bind(ordereCompleteQueue()).to(orderCompleteExchange()).with(ROUTING_KEY_ROC_ORDER_COMPLETE);
+ }
@Bean
--
Gitblit v1.9.1