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

Simplify FunctionInvocationHelper and its CE implementation

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-03-24 16:31:41 +01:00
parent 106435e91c
commit a88a8be223
2 changed files with 9 additions and 11 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/cloudevent/CloudEventsFunctionInvocationHelper.java
View File

@@ -94,12 +94,6 @@ public class CloudEventsFunctionInvocationHelper implements FunctionInvocationHe
return this.doPostProcessResult(convertedResult, targetPrefix); return this.doPostProcessResult(convertedResult, targetPrefix);
} }
@Override
public Message<?> postProcessResult(Object result, String targetProtocol) {
String targetPrefix = CloudEventMessageUtils.determinePrefixToUse(targetProtocol);
return this.doPostProcessResult(result, targetPrefix);
}
@Override @Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.applicationContext = (ConfigurableApplicationContext) applicationContext; this.applicationContext = (ConfigurableApplicationContext) applicationContext;

14
spring-cloud-function-core/src/main/java/org/springframework/cloud/function/core/FunctionInvocationHelper.java
View File

@@ -26,11 +26,15 @@ package org.springframework.cloud.function.core;
*/ */
public interface FunctionInvocationHelper<I> { public interface FunctionInvocationHelper<I> {
boolean isRetainOuputAsMessage(I input); default boolean isRetainOuputAsMessage(I input) {
return true;
};
I preProcessInput(I input, Object inputConverter); default I preProcessInput(I input, Object inputConverter) {
return input;
}
I postProcessResult(Object result, String hint); default Object postProcessResult(Object result, I input) {
return result;
I postProcessResult(Object result, I input); }
} }