kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java
@@ -60,6 +60,11 @@ */ private String routingKeyName; /** * AI返回结果队列 */ private String AIEvaluationResults; @Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host,port); @@ -137,6 +142,11 @@ } @Bean public Queue AIEvaluationResults() { return new Queue(AIEvaluationResults); } @Bean Binding bindingExchangeAIEvaluation(TopicExchange exchange) { return BindingBuilder.bind(AIEvaluation()).to(exchange).with(routingKeyName); }