From 6df37af308ff6a223838965453d90b5ed3075571 Mon Sep 17 00:00:00 2001 From: "chen.ma" Date: Sat, 14 May 2022 00:48:35 +0800 Subject: [PATCH] Add effective conditions for springcloud stream rocketmq adapter --- .../rocketmq/SpringCloudStreamRocketMQAutoConfiguration.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rocketmq/src/main/java/cn/hippo4j/springboot/starter/adapter/springcloud/stream/rocketmq/SpringCloudStreamRocketMQAutoConfiguration.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rocketmq/src/main/java/cn/hippo4j/springboot/starter/adapter/springcloud/stream/rocketmq/SpringCloudStreamRocketMQAutoConfiguration.java index 303a4197..4c51d30c 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rocketmq/src/main/java/cn/hippo4j/springboot/starter/adapter/springcloud/stream/rocketmq/SpringCloudStreamRocketMQAutoConfiguration.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rocketmq/src/main/java/cn/hippo4j/springboot/starter/adapter/springcloud/stream/rocketmq/SpringCloudStreamRocketMQAutoConfiguration.java @@ -18,6 +18,7 @@ package cn.hippo4j.springboot.starter.adapter.springcloud.stream.rocketmq; import cn.hippo4j.adapter.springcloud.stream.rocketmq.SpringCloudStreamRocketMQThreadPoolAdapter; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @@ -28,6 +29,7 @@ import org.springframework.context.annotation.Configuration; public class SpringCloudStreamRocketMQAutoConfiguration { @Bean + @ConditionalOnProperty(name = "spring.cloud.stream.rocketmq.binder.name-server") public SpringCloudStreamRocketMQThreadPoolAdapter springCloudStreamRocketMQThreadPoolAdapter() { return new SpringCloudStreamRocketMQThreadPoolAdapter(); }