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

[do-not-reply at jboss.org]

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));