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

Polishing related to merginng the previous commit as well as upgrade of Kotlin libs

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-10-25 13:28:31 +02:00
parent 4c7dfa7a73
commit e58741b6cb
4 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/BeanFactoryAwareFunctionRegistryTests.java
View File

@@ -880,9 +880,11 @@ public class BeanFactoryAwareFunctionRegistryTests {
@SuppressWarnings("unchecked")
@Override
protected Object doApply(Message<byte[]> input, FunctionInvocationWrapper targetFunction) {
MessageBuilder.fromMessage(input).setHeader("before", "foo").build();
Message<Object> result = (Message<Object>) targetFunction.apply(MessageBuilder.fromMessage(input).setHeader("before", "foo").build());
protected Object doApply(Object input, FunctionInvocationWrapper targetFunction) {
// in this test we know input is a Message
Message<?> mInput = (Message<?>) input;
MessageBuilder.fromMessage(mInput).setHeader("before", "foo").build();
Message<Object> result = (Message<Object>) targetFunction.apply(MessageBuilder.fromMessage(mInput).setHeader("before", "foo").build());
return MessageBuilder.fromMessage(result).setHeader("after", "bar").build();
}
};