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

do-not-reply at jboss.org do-not-reply at jboss.org
Tue Oct 13 08:17:56 EDT 2009


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)



More information about the hornetq-commits mailing list