TCP Test - increase wait time for close

Author: garyrussell

spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/TcpNioConnectionReadTests.java

@@ -235,7 +235,7 @@ public void removeDeadConnection(TcpConnection connection) {
 						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 void removeDeadConnection(TcpConnection connection) {
 						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 void removeDeadConnection(TcpConnection connection) {
 						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 void removeDeadConnection(TcpConnection connection) {
 						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 @@ private void whileOpen(Semaphore semaphore, final List<TcpConnection> added)
 		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");
 			}
 		}