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

GH-3713: Fix Race In Test

Browse Source
This commit is contained in:
Gary Russell
2022-02-03 09:22:33 -05:00
parent b9bc10558a
commit 413d66018e
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/TcpSenderTests.java
View File

@@ -112,6 +112,7 @@ public class TcpSenderTests {
}
chain.setInterceptor(new InterceptorFactory(), new InterceptorFactory(), new InterceptorFactory());
client.setInterceptorFactoryChain(chain);
CountDownLatch firstClosed = new CountDownLatch(1);
client.registerSender(new TcpSender() {
@Override
@@ -124,6 +125,7 @@ public class TcpSenderTests {
public synchronized void removeDeadConnection(TcpConnection connection) {
remOrder.add(99);
removes.countDown();
firstClosed.countDown();
}
});
@@ -136,6 +138,7 @@ public class TcpSenderTests {
conn = client.getConnection();
assertThat(adds.await(10, TimeUnit.SECONDS)).isTrue();
assertThat(addOrder).containsExactly(1, 2, 3, 99, 4, 5, 6, 99);
assertThat(firstClosed.await(10, TimeUnit.SECONDS)).isTrue();
conn.close();
client.stop();
assertThat(removes.await(10, TimeUnit.SECONDS)).isTrue();