[hornetq-commits] JBoss hornetq SVN: r9978 - trunk/tests/src/org/hornetq/tests/integration/management.

do-not-reply at jboss.org do-not-reply at jboss.org
Thu Dec 2 03:36:11 EST 2010


Author: ataylor
Date: 2010-12-02 03:36:11 -0500 (Thu, 02 Dec 2010)
New Revision: 9978

Modified:
   trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java
Log:
tidy up resources correctly

Modified: trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java	2010-12-02 08:35:11 UTC (rev 9977)
+++ trunk/tests/src/org/hornetq/tests/integration/management/QueueControlTest.java	2010-12-02 08:36:11 UTC (rev 9978)
@@ -53,6 +53,7 @@
    protected HornetQServer server;
 
    protected ClientSession session;
+   private ServerLocator locator;
 
    // Static --------------------------------------------------------
 
@@ -1281,7 +1282,7 @@
       server = HornetQServers.newHornetQServer(conf, mbeanServer, false);
       server.start();
 
-      ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
+      locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
       locator.setBlockOnNonDurableSend(true);
       locator.setBlockOnNonDurableSend(true);
       ClientSessionFactory sf = locator.createSessionFactory();
@@ -1294,10 +1295,14 @@
    {
       session.close();
 
+      locator.close();
+
       server.stop();
 
       session = null;
 
+      locator = null;
+
       server = null;
 
       super.tearDown();



More information about the hornetq-commits mailing list