diff --git a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/SimpleTcpNetOutboundGatewayTests.java b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/SimpleTcpNetOutboundGatewayTests.java index a304b5fc51..fce231bf93 100644 --- a/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/SimpleTcpNetOutboundGatewayTests.java +++ b/spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/SimpleTcpNetOutboundGatewayTests.java @@ -165,9 +165,9 @@ public class SimpleTcpNetOutboundGatewayTests { byte[] b = new byte[1024]; s.getInputStream().read(b); s.getOutputStream().write("OK\r\n".getBytes()); - latch2.countDown(); latch3.await(); s.close(); + latch2.countDown(); } } catch (Exception e) { e.printStackTrace(); @@ -207,9 +207,9 @@ public class SimpleTcpNetOutboundGatewayTests { if (!first) s.getOutputStream().write("OK\r\n".getBytes()); first = false; - latch2.countDown(); latch3.await(); s.close(); + latch2.countDown(); } } catch (Exception e) { e.printStackTrace();