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

do-not-reply at jboss.org do-not-reply at jboss.org
Tue Mar 30 01:58:49 EDT 2010


Author: clebert.suconic at jboss.com
Date: 2010-03-30 01:58:49 -0400 (Tue, 30 Mar 2010)
New Revision: 9009

Modified:
   trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java
   trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlUsingCoreTest.java
Log:
tweaks

Modified: trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java	2010-03-30 05:53:14 UTC (rev 9008)
+++ trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlTest.java	2010-03-30 05:58:49 UTC (rev 9009)
@@ -393,6 +393,12 @@
       Assert.assertEquals(newSample, serverControl.getMessageCounterSamplePeriod());
    }
 
+   protected void restartServer() throws Exception
+   {
+      server.stop();
+      server.start();
+   }
+   
    public void testSecuritySettings() throws Exception
    {
       HornetQServerControl serverControl = createManagementControl();
@@ -404,8 +410,7 @@
 
       // Restart the server. Those settings should be persisted
 
-      server.stop();
-      server.start();
+      restartServer();
 
       serverControl = createManagementControl();
 
@@ -473,8 +478,7 @@
                                        sendToDLAOnNoRoute,
                                        addressFullMessagePolicy);
 
-      server.stop();
-      server.start();
+      //restartServer();
       serverControl = createManagementControl();
 
       AddressSettings settings = serverControl.getAddressSettings(exactAddress);

Modified: trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlUsingCoreTest.java	2010-03-30 05:53:14 UTC (rev 9008)
+++ trunk/tests/src/org/hornetq/tests/integration/management/HornetQServerControlUsingCoreTest.java	2010-03-30 05:58:49 UTC (rev 9009)
@@ -79,7 +79,19 @@
 
       super.tearDown();
    }
+   
+   protected void restartServer() throws Exception
+   {
+      session.close();
+      
+      super.restartServer();
+      
+      ClientSessionFactory sf = HornetQClient.createClientSessionFactory(new TransportConfiguration(InVMConnectorFactory.class.getName()));
+      session = sf.createSession(false, true, true);
+      session.start();
 
+   }
+
    @Override
    protected HornetQServerControl createManagementControl() throws Exception
    {



More information about the hornetq-commits mailing list