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

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-08-23 10:54:38 -0400 (Mon, 23 Aug 2010)
New Revision: 9581

Modified:
   branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java
Log:
fix TemporaryQueueTest

Modified: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java
===================================================================
--- branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java	2010-08-23 14:52:52 UTC (rev 9580)
+++ branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/client/TemporaryQueueTest.java	2010-08-23 14:54:38 UTC (rev 9581)
@@ -60,6 +60,8 @@
 
    private ClientSessionFactory sf;
 
+   private ServerLocator locator;
+
    // Static --------------------------------------------------------
 
    // Constructors --------------------------------------------------
@@ -161,9 +163,12 @@
          }
       });
       session.close();
+      sf.close();
       // wait for the closing listeners to be fired
       Assert.assertTrue("connection close listeners not fired", latch.await(2 * TemporaryQueueTest.CONNECTION_TTL,
                                                                             TimeUnit.MILLISECONDS));
+      
+      sf = locator.createSessionFactory();
       session = sf.createSession(false, true, true);
       session.start();
 
@@ -210,7 +215,8 @@
    public void testDeleteTemporaryQueueWhenClientCrash() throws Exception
    {
       session.close();
-
+      sf.close();
+      
       final SimpleString queue = RandomUtil.randomSimpleString();
       SimpleString address = RandomUtil.randomSimpleString();
 
@@ -296,7 +302,7 @@
       server = createServer(false, configuration);
       server.start();
 
-      ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
+      locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
       locator.setConnectionTTL(TemporaryQueueTest.CONNECTION_TTL);
       sf = locator.createSessionFactory();
       session = sf.createSession(false, true, true);