From c49b95fc3576f9a5dad5bcaa6874157d5091f6e0 Mon Sep 17 00:00:00 2001 From: luliqiang <kidgrow> Date: Thu, 27 Aug 2020 09:19:27 +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 | 32 ++++++++++++++++++++++++++++++++ 1 files changed, 32 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 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