From bf1563dbb4a19380daa610eeb7d49fc4b47282e0 Mon Sep 17 00:00:00 2001 From: luliqiang <kidgrow> Date: Fri, 14 Aug 2020 15:15:16 +0800 Subject: [PATCH] Merge branch 'dev' of http://192.168.2.240:7070/r/kidgrow-microservices-platform into dev --- kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/resources/application.yml | 3 +++ kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java | 32 ++++++++++++++++++++++++++++++++ 2 files changed, 35 insertions(+), 0 deletions(-) diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/resources/application.yml b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/resources/application.yml index 42d89c8..8a63c4e 100644 --- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/resources/application.yml +++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/resources/application.yml @@ -31,6 +31,9 @@ routingKeyName: ${kidgrow.rabbitmq.routingKeyName} virtual-host: ${kidgrow.rabbitmq.virtual-host} AIEvaluationResults: AIEvaluationResults_${spring.profiles.active} + BoneAgeEvaluationData: BoneAgeEvaluationData_${spring.profiles.active} + ChildRecordData: ChildRecordData_${spring.profiles.active} + ReportData: ReportData_${spring.profiles.active} #开启重试机制 listener: simple: 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 bbe3d76..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 @@ -65,6 +65,21 @@ */ private String AIEvaluationResults; + /** + * 骨龄评价统计 + */ + private String BoneAgeEvaluationData; + + /** + * 档案统计 + */ + private String ChildRecordData; + + /** + * 报告统计 + */ + private String ReportData; + @Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host,port); @@ -147,6 +162,23 @@ } @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