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

[do-not-reply at jboss.org]

Author: ataylor
Date: 2010-12-02 03:41:46 -0500 (Thu, 02 Dec 2010)
New Revision: 9980

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

Modified: trunk/tests/src/org/hornetq/tests/integration/management/NotificationTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/NotificationTest.java	2010-12-02 08:38:25 UTC (rev 9979)
+++ trunk/tests/src/org/hornetq/tests/integration/management/NotificationTest.java	2010-12-02 08:41:46 UTC (rev 9980)
@@ -53,6 +53,7 @@
    private ClientConsumer notifConsumer;
 
    private SimpleString notifQueue;
+   private ServerLocator locator;
 
    // Static --------------------------------------------------------
 
@@ -215,7 +216,7 @@
       service = HornetQServers.newHornetQServer(conf, false);
       service.start();
 
-      ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(InVMConnectorFactory.class.getName()));
+      locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(InVMConnectorFactory.class.getName()));
       ClientSessionFactory sf = locator.createSessionFactory();
       session = sf.createSession(false, true, true);
       session.start();
@@ -235,6 +236,11 @@
       session.deleteQueue(notifQueue);
       session.close();
 
+      if(locator != null)
+      {
+         locator.close();
+      }
+
       service.stop();
 
       super.tearDown();