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

GH-1240 Fix logging for ineligible functions

Browse Source 
Resolves #1240
This commit is contained in:
Oleg Zhurakousky
2025-03-20 10:28:25 +01:00
parent 9c59ecf8bf
commit 96e16cc712
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistry.java
View File

@@ -124,6 +124,9 @@ public class BeanFactoryAwareFunctionRegistry extends SimpleFunctionRegistry imp
if (!this.applicationContext.containsBean(functionDefinition) || !KotlinDetector.isKotlinType(this.applicationContext.getBean(functionDefinition).getClass())) { if (!this.applicationContext.containsBean(functionDefinition) || !KotlinDetector.isKotlinType(this.applicationContext.getBean(functionDefinition).getClass())) {
functionDefinition = this.normalizeFunctionDefinition(functionDefinition); functionDefinition = this.normalizeFunctionDefinition(functionDefinition);
} }
if (!isFunctionDefinitionEligible(functionDefinition)) {
return null;
}
if (!StringUtils.hasText(functionDefinition)) { if (!StringUtils.hasText(functionDefinition)) {
Collection<Object> functionalBeans = this.getNames(null).stream() Collection<Object> functionalBeans = this.getNames(null).stream()
.filter(name -> !RoutingFunction.FUNCTION_NAME.equals(name)) .filter(name -> !RoutingFunction.FUNCTION_NAME.equals(name))
@@ -134,9 +137,7 @@ public class BeanFactoryAwareFunctionRegistry extends SimpleFunctionRegistry imp
+ "use 'spring.cloud.function.definition' property to explicitly define it. "); + "use 'spring.cloud.function.definition' property to explicitly define it. ");
} }
} }
if (!isFunctionDefinitionEligible(functionDefinition)) {
return null;
}
FunctionInvocationWrapper function = this.doLookup(type, functionDefinition, expectedOutputMimeTypes); FunctionInvocationWrapper function = this.doLookup(type, functionDefinition, expectedOutputMimeTypes);
Object syncInstance = functionDefinition == null ? this : functionDefinition; Object syncInstance = functionDefinition == null ? this : functionDefinition;
synchronized (syncInstance) { synchronized (syncInstance) {