Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix race condition in AsyncMessagingTemplateTests

Browse Source
This commit is contained in:
abilan
2023-02-22 10:14:32 -05:00
parent 42b11d2d0a
commit ca7736d2a6
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-integration-core/src/test/java/org/springframework/integration/core/AsyncMessagingTemplateTests.java
View File

@@ -38,6 +38,7 @@ import org.springframework.messaging.support.GenericMessage;
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatExceptionOfType;
import static org.awaitility.Awaitility.await;
/**
* @author Mark Fisher
@@ -401,7 +402,7 @@ public class AsyncMessagingTemplateTests {
}
@Test
public void executionException() throws Throwable {
public void executionException() {
DirectChannel channel = new DirectChannel();
channel.subscribe(new EchoHandler(-1));
AsyncMessagingTemplate template = new AsyncMessagingTemplate();
@@ -427,7 +428,7 @@ public class AsyncMessagingTemplateTests {
assertThatExceptionOfType(CancellationException.class)
.isThrownBy(result::get);
assertThat(handler.interrupted).as("handler should have been interrupted").isTrue();
await().until(() -> handler.interrupted);
}