[hornetq-commits] JBoss hornetq SVN: r10186 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-02-08 13:08:54 -0500 (Tue, 08 Feb 2011)
New Revision: 10186

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingOrderTest.java
Log:
Fixing test

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingOrderTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingOrderTest.java	2011-02-07 22:10:53 UTC (rev 10185)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/client/PagingOrderTest.java	2011-02-08 18:08:54 UTC (rev 10186)
@@ -122,7 +122,7 @@
 
       super.tearDown();
    }
-
+   
    public void testOrder1() throws Throwable
    {
       boolean persistentMessages = true;
@@ -216,18 +216,20 @@
             sessionServer.close(true);
          }
          
-         
          OperationContextImpl.getContext().waitCompletion();
          
          assertEquals(numberOfMessages - 100, queue.getMessageCount());
          assertEquals(numberOfMessages, queue.getMessagesAdded());
+         
+         session.close();
+         
+         session = null;
 
-         OperationContextImpl.getContext().waitCompletion();
+         sf.close();
+         sf = locator.createSessionFactory();
 
-         ((ClientSessionFactoryImpl)sf).stopPingingAfterOne();
+         locator = createInVMNonHALocator();
 
-         sf = locator.createSessionFactory();
-
          session = sf.createSession(true, true, 0);
 
          session.start();
@@ -241,6 +243,10 @@
             assertEquals(i, message.getIntProperty("id").intValue());
             message.acknowledge();
          }
+         
+         session.close();
+         
+         sf.close();
 
       }
       catch (Throwable e)