SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removed cast to SmartInitializingSingleton for FunctionCatalog

Browse Source
This commit is contained in:
Oleg Zhurakousky
2019-07-29 15:33:32 +02:00
parent a69f9b18d3
commit 34ea0144ec
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/BinderFactoryAutoConfiguration.java
View File

@@ -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;