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

Fix failing test

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-07-20 15:38:28 +02:00
parent 76e317c7e9
commit 6b263a29d0
1 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -94,7 +94,7 @@ public class SourceToFunctionsSupportTests {
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
assertThat(target.receive(1000).getPayload())
assertThat(target.receive(5000).getPayload())
.isEqualTo("HELLO FUNCTION:HELLO FUNCTION".getBytes(StandardCharsets.UTF_8));
}
}
@@ -108,7 +108,7 @@ public class SourceToFunctionsSupportTests {
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
assertThat(target.receive(1000).getPayload())
assertThat(target.receive(5000).getPayload())
.isEqualTo("HELLO FUNCTION:HELLO FUNCTION".getBytes(StandardCharsets.UTF_8));
}
}
@@ -122,7 +122,7 @@ public class SourceToFunctionsSupportTests {
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
String result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
String result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("1");
}
}
@@ -136,7 +136,7 @@ public class SourceToFunctionsSupportTests {
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
String result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
String result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("1:1");
}
}
@@ -150,7 +150,7 @@ public class SourceToFunctionsSupportTests {
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
String result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
String result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("1:1");
}
}
@@ -163,11 +163,11 @@ public class SourceToFunctionsSupportTests {
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
String result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
String result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("0");
result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("1");
result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("2");
}
}
@@ -181,11 +181,11 @@ public class SourceToFunctionsSupportTests {
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
String result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
String result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("0:0");
result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("1:1");
result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("2:2");
}
}
@@ -199,11 +199,11 @@ public class SourceToFunctionsSupportTests {
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
String result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
String result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("0:0");
result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("1:1");
result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("2:2");
}
}
@@ -217,11 +217,11 @@ public class SourceToFunctionsSupportTests {
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
String result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
String result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("0:0");
result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("1:1");
result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
result = new String(target.receive(5000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("2:2");
}
}