Author: clebert.suconic(a)jboss.com Date: 2011-08-31 14:24:06 -0400 (Wed, 31 Aug 2011) New Revision: 11261 Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java Log: fixing thread leakage Modified: branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java =================================================================== --- branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java 2011-08-31 18:20:37 UTC (rev 11260) +++ branches/Branch_2_2_EAP_cluster_clean3/tests/src/org/hornetq/tests/util/JMSClusteredTestBase.java 2011-08-31 18:24:06 UTC (rev 11261) @@ -113,9 +113,11 @@ jmsServer1.start(); jmsServer1.activated(); + waitForServer(jmsServer1.getHornetQServer()); jmsServer2.start(); jmsServer2.activated(); + waitForServer(jmsServer2.getHornetQServer()); cf1 = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, new TransportConfiguration(InVMConnectorFactory.class.getName(), generateInVMParams(0)));