[hornetq-commits] JBoss hornetq SVN: r8496 - trunk/tests/src/org/hornetq/tests/integration/remoting.

Author: ataylor Date: 2009-12-02 05:36:54 -0500 (Wed, 02 Dec 2009) New Revision: 8496 Modified: trunk/tests/src/org/hornetq/tests/integration/remoting/PingTest.java Log: fixed ping test Modified: trunk/tests/src/org/hornetq/tests/integration/remoting/PingTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/remoting/PingTest.java 2009-12-02 10:12:45 UTC (rev 8495) +++ trunk/tests/src/org/hornetq/tests/integration/remoting/PingTest.java 2009-12-02 10:36:54 UTC (rev 8496) @@ -228,7 +228,7 @@ ClientSession session = csf.createSession(false, true, true); - assertEquals(1, ((ClientSessionFactoryInternal)csf).numConnections()); + assertEquals(1, csf.numConnections()); session.addFailureListener(clientListener); @@ -296,7 +296,7 @@ { // server must received at least one ping from the client to pass // so that the server connection TTL is configured with the client value - final CountDownLatch pingOnServerLatch = new CountDownLatch(1); + final CountDownLatch pingOnServerLatch = new CountDownLatch(2); server.getRemotingService().addInterceptor(new Interceptor() { @@ -363,14 +363,14 @@ serverConn.addCloseListener(serverListener); - assertTrue("server has not received any ping from the client" , pingOnServerLatch.await(2000, TimeUnit.MILLISECONDS)); + assertTrue("server has not received any ping from the client" , pingOnServerLatch.await(4000, TimeUnit.MILLISECONDS)); // we let the server receives at least 1 ping (so that it uses the client ConnectionTTL value) //Setting the handler to null will prevent server sending pings back to client serverConn.getChannel(0, -1).setHandler(null); - assertTrue(clientLatch.await(4 * CLIENT_FAILURE_CHECK_PERIOD, TimeUnit.MILLISECONDS)); + assertTrue(clientLatch.await(8 * CLIENT_FAILURE_CHECK_PERIOD, TimeUnit.MILLISECONDS)); //Server connection will be closed too, when client closes client side connection after failure is detected assertTrue(serverLatch.await(2 * RemotingServiceImpl.CONNECTION_TTL_CHECK_INTERVAL, TimeUnit.MILLISECONDS));