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

Relax type rules for outputMessageEnricher

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-10-15 19:21:37 +02:00
parent a1b2c07221
commit 0cb5483d0a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -387,7 +387,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
* It is not intended to remain here and will be removed as soon as particular elements * It is not intended to remain here and will be removed as soon as particular elements
* of stream will be refactored to address this. * of stream will be refactored to address this.
*/ */
private Function<Object, Message> enhancer; private Function<Object, Object> enhancer;
FunctionInvocationWrapper(FunctionInvocationWrapper function) { FunctionInvocationWrapper(FunctionInvocationWrapper function) {
this.skipOutputConversion = function.skipOutputConversion; this.skipOutputConversion = function.skipOutputConversion;
@@ -432,7 +432,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
* It is not intended to remain here and will be removed as soon as particular elements * It is not intended to remain here and will be removed as soon as particular elements
* of stream will be refactored to address this. * of stream will be refactored to address this.
*/ */
public Function<Object, Message> getEnhancer() { public Function<Object, Object> getEnhancer() {
return this.enhancer; return this.enhancer;
} }
@@ -443,7 +443,7 @@ public class SimpleFunctionRegistry implements FunctionRegistry, FunctionInspect
* It is not intended to remain here and will be removed as soon as particular elements * It is not intended to remain here and will be removed as soon as particular elements
* of stream will be refactored to address this. * of stream will be refactored to address this.
*/ */
public void setEnhancer(Function<Object, Message> enhancer) { public void setEnhancer(Function<Object, Object> enhancer) {
this.enhancer = enhancer; this.enhancer = enhancer;
} }