From 34ea0144ec7619b7abcc98f181c1045d5a765e79 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 29 Jul 2019 15:33:32 +0200 Subject: [PATCH] Removed cast to SmartInitializingSingleton for FunctionCatalog --- .../stream/config/BinderFactoryAutoConfiguration.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java index 27a523438..6156ef821 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java @@ -33,7 +33,6 @@ import org.apache.commons.logging.LogFactory; import org.springframework.beans.BeansException; import org.springframework.beans.factory.BeanCreationException; -import org.springframework.beans.factory.SmartInitializingSingleton; import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.config.BeanDefinition; import org.springframework.beans.factory.config.BeanFactoryPostProcessor; @@ -289,9 +288,9 @@ public class BinderFactoryAutoConfiguration { private String determineFunctionName(FunctionCatalog catalog, Environment environment) { String name = environment.getProperty("spring.cloud.stream.function.definition"); - if (!StringUtils.hasText(name) && catalog.size() == 0) { - ((SmartInitializingSingleton) catalog).afterSingletonsInstantiated(); - } +// if (!StringUtils.hasText(name) && catalog.size() == 0) { +// ((SmartInitializingSingleton) catalog).afterSingletonsInstantiated(); +// } if (!StringUtils.hasText(name) && Boolean.parseBoolean( environment.getProperty("spring.cloud.function.routing.enabled", "false"))) { name = RoutingFunction.FUNCTION_NAME;