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

Merge pull request #454 from garyrussell/INT-2581

Browse Source 
* INT-2581:
  INT-2581 Fix Failing Test (Timing)
This commit is contained in:
Oleg Zhurakousky
2012-05-23 13:45:00 -04:00
parent 73164ff82a 33c0da2341
commit f060a714a4
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/SocketSupportTests.java
View File

@@ -144,9 +144,11 @@ public class SocketSupportTests {
});
final AtomicInteger ppSocketCountServer = new AtomicInteger();
final AtomicInteger ppServerSocketCountServer = new AtomicInteger();
final CountDownLatch latch = new CountDownLatch(1);
TcpSocketSupport serverSocketSupport = new TcpSocketSupport() {
public void postProcessSocket(Socket socket) {
ppSocketCountServer.incrementAndGet();
latch.countDown();
}
public void postProcessServerSocket(ServerSocket serverSocket) {
ppServerSocketCountServer.incrementAndGet();
@@ -156,6 +158,7 @@ public class SocketSupportTests {
serverConnectionFactory.start();
waitListening(serverConnectionFactory);
clientConnectionFactory.getConnection().send(new GenericMessage<String>("Hello, world!"));
assertTrue(latch.await(10, TimeUnit.SECONDS));
assertEquals(0, ppServerSocketCountClient.get());
assertEquals(1, ppSocketCountClient.get());