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

GH-985 Ensure PassThruFunction is not pre/post processed

Browse Source 
Resolves #985
This commit is contained in:
Oleg Zhurakousky
2023-01-11 16:35:37 +01:00
parent 2be70c5829
commit 4dcf0be7b3
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -871,7 +871,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry {
inputValue = this.extractValueFromOriginalValueHolderIfNecessary(value); inputValue = this.extractValueFromOriginalValueHolderIfNecessary(value);
} }
if (inputValue instanceof Message && !this.isInputTypeMessage()) { if (!(this.target instanceof PassThruFunction) && inputValue instanceof Message && !this.isInputTypeMessage()) {
inputValue = ((Message) inputValue).getPayload(); inputValue = ((Message) inputValue).getPayload();
} }
@@ -1001,7 +1001,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
private boolean isInputConversionNecessary(Object input, Type type) { private boolean isInputConversionNecessary(Object input, Type type) {
if (type == null || this.getRawClassFor(type) == Void.class || this.target instanceof RoutingFunction || this.isComposed()) { if (type == null || this.getRawClassFor(type) == Void.class || this.target instanceof RoutingFunction || this.isComposed() || this.target instanceof PassThruFunction) {
if (this.getRawClassFor(type) == Void.class) { if (this.getRawClassFor(type) == Void.class) {
if (input instanceof Message) { if (input instanceof Message) {
input = ((Message) input).getPayload(); input = ((Message) input).getPayload();