From d04842d52359edda31cd5e30f6e6c542569bdea9 Mon Sep 17 00:00:00 2001 From: zhaoxiaohao <913652501@qq.com> Date: Wed, 22 Jul 2020 19:25:42 +0800 Subject: [PATCH] Merge branch 'dev' of http://192.168.2.240:7070/r/kidgrow-microservices-platform into dev --- kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java | 24 ++++++++++++++++++++++-- 1 files changed, 22 insertions(+), 2 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 bcf5d4f..02fda0d 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 @@ -127,7 +127,27 @@ } @Bean - Binding bindingExchangeMessage(Queue kidgrowQueue, TopicExchange exchange) { - return BindingBuilder.bind(kidgrowQueue).to(exchange).with(routingKeyName); + Binding bindingExchangeMessage(TopicExchange exchange) { + return BindingBuilder.bind(KidgrowQueue()).to(exchange).with(routingKeyName); + } + + @Bean + public Queue AIEvaluation() { + return new Queue("AIEvaluation"); + } + + @Bean + Binding bindingExchangeAIEvaluation(TopicExchange exchange) { + return BindingBuilder.bind(AIEvaluation()).to(exchange).with(routingKeyName); + } + + @Bean + public Queue AdvancedEvaluation() { + return new Queue("AdvancedEvaluation"); + } + + @Bean + Binding bindingExchangeAdvancedEvaluation(TopicExchange exchange) { + return BindingBuilder.bind(AdvancedEvaluation()).to(exchange).with(routingKeyName); } } -- Gitblit v1.8.0