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

Fix condition for payload extraction before invocation

Browse Source 
We need to only extract payload for cases where input is coming from SCF-Web
This commit is contained in:
Oleg Zhurakousky
2020-04-22 13:56:32 +02:00
parent 9ca0053cbb
commit 40c208c124
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -524,7 +524,8 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
private Object invokeFunction(Object input) {
Message incomingMessage = null;
if (!this.functionDefinition.startsWith(RoutingFunction.FUNCTION_NAME)) {
if (input instanceof Message && !FunctionTypeUtils.isMessage(FunctionTypeUtils.getInputType(functionType, 0))) {
if (input instanceof Message && !FunctionTypeUtils.isMessage(FunctionTypeUtils.getInputType(functionType, 0))
&& ((Message) input).getHeaders().containsKey("scf-func-name")) {
incomingMessage = (Message) input;
input = incomingMessage.getPayload();
}