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

Perf improvement

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-03-18 14:47:44 +01:00
parent b777988086
commit c5f176b978
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistry.java
View File

@@ -53,7 +53,6 @@ import org.springframework.cloud.function.context.FunctionProperties.FunctionCon
import org.springframework.cloud.function.context.FunctionRegistration;
import org.springframework.cloud.function.context.FunctionRegistry;
import org.springframework.cloud.function.context.config.RoutingFunction;
import org.springframework.cloud.function.context.message.MessageUtils;
import org.springframework.cloud.function.core.FunctionInvocationHelper;
import org.springframework.cloud.function.json.JsonMapper;
import org.springframework.context.expression.BeanFactoryResolver;
@@ -542,14 +541,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry {
if (logger.isDebugEnabled() && !(input instanceof Publisher)) {
logger.debug("Invoking function " + this);
}
Object result;
if (input instanceof Message && ((Message) input).getHeaders().containsKey(MessageUtils.TARGET_PROTOCOL) && ((Message) input).getHeaders().get(MessageUtils.TARGET_PROTOCOL).equals("streamBridge")) {
result = input;
}
else {
result = this.doApply(input);
}
// Object result = this.doApply(input);
Object result = (this.getTarget() instanceof PassThruFunction) ? input : this.doApply(input);
if (result != null && this.outputType != null) {
result = this.convertOutputIfNecessary(result, this.outputType, this.expectedOutputContentType);
@@ -1443,4 +1435,11 @@ public class SimpleFunctionRegistry implements FunctionRegistry {
return this.originalMessage;
}
}
public static class PassThruFunction implements Function<Object, Object> {
@Override
public Object apply(Object t) {
return t;
}
}
}