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

Add support for default function lookup to RSocket

Browse Source
This commit is contained in:
Oleg Zhurakousky
2020-08-05 10:15:29 +02:00
parent 99b158b932
commit dcb3a9ffbc
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-cloud-function-rsocket/src/main/java/org/springframework/cloud/function/rsocket/RSocketAutoConfiguration.java
View File

@@ -82,6 +82,13 @@ public class RSocketAutoConfiguration {
@Override @Override
public void afterPropertiesSet() throws Exception { public void afterPropertiesSet() throws Exception {
String definition = this.functionProperties.getDefinition(); String definition = this.functionProperties.getDefinition();
if (!StringUtils.hasText(definition)) {
FunctionInvocationWrapper f = this.functionCatalog.lookup("");
if (f != null) {
definition = f.getFunctionDefinition();
}
}
Assert.isTrue(StringUtils.hasText(definition), "Failed to determine target function for RSocket.");
this.registerRsocketForwardingFunctionIfNecessary(definition); this.registerRsocketForwardingFunctionIfNecessary(definition);
//TODO externalize content-type //TODO externalize content-type
FunctionInvocationWrapper function = functionCatalog.lookup(definition, "application/json"); FunctionInvocationWrapper function = functionCatalog.lookup(definition, "application/json");