[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