From e2ba60f02157e069a0a81ea64d81bd4e63c7dc5e Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 1 Nov 2019 10:22:58 -0400 Subject: [PATCH] TCP Test - increase wait time for close --- .../ip/tcp/connection/TcpNioConnectionReadTests.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/TcpNioConnectionReadTests.java b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/TcpNioConnectionReadTests.java index 6749ff1c81..128a9b72a4 100644 --- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/TcpNioConnectionReadTests.java +++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/TcpNioConnectionReadTests.java @@ -235,7 +235,7 @@ public class TcpNioConnectionReadTests { s -> assertThat(s).contains("Connection is closed")); assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue(); - assertThat(removed.size() > 0).isTrue(); + assertThat(removed).hasSizeGreaterThan(0); scf.stop(); done.countDown(); } @@ -287,7 +287,7 @@ public class TcpNioConnectionReadTests { s -> assertThat(s).contains("Connection is closed")); assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue(); - assertThat(removed.size() > 0).isTrue(); + assertThat(removed).hasSizeGreaterThan(0); scf.stop(); done.countDown(); } @@ -339,7 +339,7 @@ public class TcpNioConnectionReadTests { s -> assertThat(s).contains("Connection is closed")); assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue(); - assertThat(removed.size() > 0).isTrue(); + assertThat(removed).hasSizeGreaterThan(0); scf.stop(); done.countDown(); } @@ -447,7 +447,7 @@ public class TcpNioConnectionReadTests { s -> assertThat(s).contains("Connection is closed")); assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue(); - assertThat(removed.size() > 0).isTrue(); + assertThat(removed).hasSizeGreaterThan(0); scf.stop(); } @@ -536,7 +536,7 @@ public class TcpNioConnectionReadTests { assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue(); while (added.get(0).isOpen()) { Thread.sleep(50); - if (n++ > 200) { + if (n++ > 400) { fail("Failed to close socket"); } }