From 5d3b07a294a1bd3d6e01f3f2f9e0ec8b80f7cc0f Mon Sep 17 00:00:00 2001
From: zhaoxiaohao <913652501@qq.com>
Date: Fri, 14 Aug 2020 15:54:12 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev

---
 kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java |   42 ++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 42 insertions(+), 0 deletions(-)

diff --git a/kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java b/kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java
index 02fda0d..f26e939 100644
--- a/kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java
+++ b/kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java
@@ -60,6 +60,26 @@
      */
     private String routingKeyName;
 
+    /**
+     * AI返回结果队列
+     */
+    private String AIEvaluationResults;
+
+    /**
+     * 骨龄评价统计
+     */
+    private String BoneAgeEvaluationData;
+
+    /**
+     * 档案统计
+     */
+    private String ChildRecordData;
+
+    /**
+     * 报告统计
+     */
+    private String ReportData;
+
     @Bean
     public ConnectionFactory connectionFactory() {
         CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host,port);
@@ -137,6 +157,28 @@
     }
 
     @Bean
+    public Queue AIEvaluationResults() {
+        return new Queue(AIEvaluationResults);
+    }
+
+    @Bean
+    public Queue BoneAgeEvaluationData() {
+        return new Queue(BoneAgeEvaluationData);
+    }
+
+    @Bean
+    public Queue ChildRecordData() {
+        return new Queue(ChildRecordData);
+    }
+
+
+    @Bean
+    public Queue ReportData() {
+        return new Queue(ReportData);
+    }
+
+
+    @Bean
     Binding bindingExchangeAIEvaluation(TopicExchange exchange) {
         return BindingBuilder.bind(AIEvaluation()).to(exchange).with(routingKeyName);
     }

--
Gitblit v1.8.0