Author: jmesnil
Date: 2009-10-13 08:17:56 -0400 (Tue, 13 Oct 2009)
New Revision: 8086
Modified:
trunk/tests/src/org/hornetq/tests/integration/management/QueueControlUsingCoreTest.java
Log:
ensure created sessions are properly closed
Modified:
trunk/tests/src/org/hornetq/tests/integration/management/QueueControlUsingCoreTest.java
===================================================================
---
trunk/tests/src/org/hornetq/tests/integration/management/QueueControlUsingCoreTest.java 2009-10-13
10:20:05 UTC (rev 8085)
+++
trunk/tests/src/org/hornetq/tests/integration/management/QueueControlUsingCoreTest.java 2009-10-13
12:17:56 UTC (rev 8086)
@@ -51,10 +51,6 @@
@Override
protected QueueControl createManagementControl(final SimpleString address, final
SimpleString queue) throws Exception
{
- ClientSessionFactory sf = new ClientSessionFactoryImpl(new
TransportConfiguration(InVMConnectorFactory.class.getName()));
- session = sf.createSession(false, true, true);
- session.start();
-
return new QueueControl()
{
private final CoreMessagingProxy proxy = new CoreMessagingProxy(session,
@@ -275,6 +271,16 @@
// Protected -----------------------------------------------------
@Override
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+
+ ClientSessionFactory sf = new ClientSessionFactoryImpl(new
TransportConfiguration(InVMConnectorFactory.class.getName()));
+ session = sf.createSession(false, true, true);
+ session.start();
+ }
+
+ @Override
protected void tearDown() throws Exception
{
if (session != null)
Show replies by date