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

StreamBridge test cleanup

Browse Source 
- Fix a race condtion that causes a CI failure
This commit is contained in:
Soby Chacko
2023-09-28 12:47:35 -04:00
parent a74b3d5e99
commit db5b717fc4
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/StreamBridgeTests.java
View File

@@ -575,22 +575,20 @@ public class StreamBridgeTests {
}
@Test
void testSendingMessageToOutputOfExistingSupplier() throws Exception {
void testSendingMessageToOutputOfExistingSupplier() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(TestChannelBinderConfiguration
.getCompleteConfiguration(TestConfiguration.class))
.web(WebApplicationType.NONE).run("--spring.cloud.stream.output-bindings=supplier;foo",
"--spring.jmx.enabled=false")) {
.web(WebApplicationType.NONE).run("--spring.cloud.stream.output-bindings=supplier;foo")) {
StreamBridge bridge = context.getBean(StreamBridge.class);
bridge.send("supplier-out-0", "blah");
bridge.send("foo-out-0", "b");
OutputDestination outputDestination = context.getBean(OutputDestination.class);
Message<byte[]> message = outputDestination.receive(100, "foo-out-0");
assertThat(new String(message.getPayload())).isEqualTo("b");
message = outputDestination.receive(100, "supplier-out-0");
assertThat(new String(message.getPayload())).isEqualTo("hello");
bridge.send("supplier-out-0", "blah");
message = outputDestination.receive(100, "supplier-out-0");
assertThat(new String(message.getPayload())).isEqualTo("blah");
}