SpringCloud/stream-applications-acceptance-tests
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update stream applications versions

Browse Source
This commit is contained in:
David Turanski
2021-05-19 10:28:26 -04:00
parent 39b620d710
commit 2b47009339
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
stream-applications-integration-tests/pom.xml
View File

@@ -16,8 +16,8 @@
<properties>
<java.version>1.8</java.version>
<java-functions.version>1.0.0-M4</java-functions.version>
<stream-applications.version>3.0.0-M4</stream-applications.version>
<java-functions.version>1.0.3-SNAPSHOT</java-functions.version>
<stream-applications.version>3.0.2-SNAPSHOT</stream-applications.version>
<mariadb-client.version>2.6.2</mariadb-client.version>
<test-containers.version>1.15.1</test-containers.version>
<maven-checkstyle-plugin.version>3.1.0</maven-checkstyle-plugin.version>

7
stream-applications-integration-tests/src/test/java/org/springframework/cloud/stream/apps/integration/test/source/http/HttpSourceTests.java
View File

@@ -29,6 +29,7 @@ import org.testcontainers.containers.wait.strategy.Wait;
import reactor.core.publisher.Mono;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.stream.app.test.integration.AppLog;
import org.springframework.cloud.stream.app.test.integration.OutputMatcher;
import org.springframework.cloud.stream.app.test.integration.StreamAppContainer;
import org.springframework.cloud.stream.app.test.integration.StreamAppContainerTestUtils;
@@ -56,7 +57,7 @@ public abstract class HttpSourceTests {
.withEnv("SERVER_PORT", String.valueOf(serverPort))
.withExposedPorts(serverPort)
.waitingFor(Wait.forListeningPort().withStartupTimeout(DEFAULT_DURATION));
source.start();
source.withLogConsumer(AppLog.appLog("http")).start();
}
@Autowired
@@ -74,8 +75,8 @@ public abstract class HttpSourceTests {
webClient
.post()
.uri("http://localhost:" + source.getMappedPort(serverPort))
.contentType(MediaType.TEXT_PLAIN)
.body(Mono.just("Hello"), String.class)
.contentType(MediaType.valueOf("application/x-www-form-url-encoded"))
.body(Mono.just("Hello".getBytes()), byte[].class)
.exchange()
.subscribe(r -> {
httpStatus.set(r.statusCode());