[hornetq-commits] JBoss hornetq SVN: r9982 - trunk/tests/src/org/hornetq/tests/integration/management.
do-not-reply at jboss.org
do-not-reply at jboss.org
Thu Dec 2 03:45:08 EST 2010
Author: ataylor
Date: 2010-12-02 03:45:07 -0500 (Thu, 02 Dec 2010)
New Revision: 9982
Modified:
trunk/tests/src/org/hornetq/tests/integration/management/DivertControlUsingCoreTest.java
Log:
tidy up resources correctly
Modified: trunk/tests/src/org/hornetq/tests/integration/management/DivertControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/DivertControlUsingCoreTest.java 2010-12-02 08:44:21 UTC (rev 9981)
+++ trunk/tests/src/org/hornetq/tests/integration/management/DivertControlUsingCoreTest.java 2010-12-02 08:45:07 UTC (rev 9982)
@@ -39,6 +39,7 @@
// Attributes ----------------------------------------------------
private ClientSession session;
+ private ServerLocator locator;
// Static --------------------------------------------------------
@@ -49,7 +50,6 @@
@Override
protected DivertControl createManagementControl(final String name) throws Exception
{
- ServerLocator locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
ClientSessionFactory sf = locator.createSessionFactory();
session = sf.createSession(false, true, true);
session.start();
@@ -102,7 +102,16 @@
// Protected -----------------------------------------------------
+
@Override
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+
+ locator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(UnitTestCase.INVM_CONNECTOR_FACTORY));
+ }
+
+ @Override
protected void tearDown() throws Exception
{
if (session != null)
@@ -110,6 +119,11 @@
session.close();
}
+ if(locator != null)
+ {
+ locator.close();
+ }
+
super.tearDown();
}
More information about the hornetq-commits
mailing list