[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