[hornetq-commits] JBoss hornetq SVN: r9443 - branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2010-07-21 05:43:15 -0400 (Wed, 21 Jul 2010)
New Revision: 9443

Modified:
   branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/OrderTest.java
   branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/RedeliveryConsumerTest.java
Log:
test fixes

Modified: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/OrderTest.java
===================================================================
--- branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/OrderTest.java	2010-07-21 09:32:32 UTC (rev 9442)
+++ branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/OrderTest.java	2010-07-21 09:43:15 UTC (rev 9443)
@@ -112,6 +112,7 @@
                started = true;
                server.stop();
                server.start();
+               sf = locator.createSessionFactory();
             }
 
             session = sf.createSession(true, true);

Modified: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/RedeliveryConsumerTest.java
===================================================================
--- branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/RedeliveryConsumerTest.java	2010-07-21 09:32:32 UTC (rev 9442)
+++ branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/RedeliveryConsumerTest.java	2010-07-21 09:43:15 UTC (rev 9443)
@@ -136,6 +136,7 @@
          session.close();
          server.stop();
          server.start();
+         factory = locator.createSessionFactory();
          session = factory.createSession(false, false, false);
          session.start();
          consumer = session.createConsumer(ADDRESS);
@@ -158,6 +159,7 @@
                session.close();
                server.stop();
                server.start();
+               factory = locator.createSessionFactory();
                session = factory.createSession(false, false, false);
                session.start();
                consumer = session.createConsumer(ADDRESS);