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

Add Message and MessageConverter to the list of classes loaded by deployer

Browse Source
This commit is contained in:
Oleg Zhurakousky
2020-03-02 15:14:48 +01:00
parent df32fd6954
commit 202d617edd
2 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-cloud-function-deployer/src/it/bootapp-with-scf/src/main/java/function/example/SimpleFunctionAppApplication.java
View File

@@ -5,6 +5,8 @@ import java.util.function.Function;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
@SpringBootApplication
public class SimpleFunctionAppApplication {
@@ -14,9 +16,13 @@ public class SimpleFunctionAppApplication {
}
@Bean
public Function<String, String> uppercase() {
public Function<Message<String>, Message<String>> uppercase() {
System.out.println("==> CREATING 'uppercase' FUNCTION bean");
return new UpperCaseFunction();
return message -> {
UpperCaseFunction func = new UpperCaseFunction();
String result = func.apply(message.getPayload());
return MessageBuilder.withPayload(result).build();
};
}
@Bean

6
spring-cloud-function-deployer/src/main/java/org/springframework/cloud/function/deployer/FunctionArchiveDeployer.java
View File

@@ -162,9 +162,13 @@ class FunctionArchiveDeployer extends JarLauncher {
private boolean shouldLoadViaDeployerLoader(String name) {
return name.startsWith("org.reactivestreams")
|| name.startsWith("reactor.");
|| name.startsWith("reactor.")
|| name.startsWith("org.springframework.messaging.Message")
|| name.startsWith("org.springframework.messaging.converter.MessageConverter");
}
private String discoverFunctionClassName(FunctionDeployerProperties functionProperties) {
try {
return StringUtils.hasText(functionProperties.getFunctionClass())