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

Fix Spring Integration DSL calls

Browse Source 
upgrade reactor version
This commit is contained in:
Oleg Zhurakousky
2020-07-15 10:01:20 +02:00
parent 725d60bdd4
commit 839e0267f7
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@@ -23,7 +23,7 @@
</scm>
<properties>
<java.version>1.8</java.version>
<reactor.version>Dysprosium-SR6</reactor.version>
<reactor.version>2020.0.0-M1</reactor.version>
<objenesis.version>2.1</objenesis.version>
<spring-cloud-function.version>3.1.0-SNAPSHOT</spring-cloud-function.version>
<maven-checkstyle-plugin.failsOnError>true</maven-checkstyle-plugin.failsOnError>

2
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java
View File

@@ -246,7 +246,7 @@ public class FunctionConfiguration {
taskScheduler.schedule(() -> { }, Instant.now()); // will keep AC alive
}
else { // implies pollable
integrationFlowBuilder = IntegrationFlows.from(supplier);
integrationFlowBuilder = IntegrationFlows.fromSupplier(supplier);
if (splittable) {
integrationFlowBuilder = integrationFlowBuilder.split();
}

2
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java
View File

@@ -379,7 +379,7 @@ public class SourceToFunctionsSupportTests {
.withPayload("hello function")
.setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.TEXT_PLAIN)
.build();
return IntegrationFlows.from(messageSource).channel(source.output()).get();
return IntegrationFlows.fromSupplier(messageSource).channel(source.output()).get();
}
}