[jboss-cvs] JBoss Messaging SVN: r2983 - trunk/tests/src/org/jboss/test/messaging/jms/clustering.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2007-08-08 16:38:27 -0400 (Wed, 08 Aug 2007)
New Revision: 2983

Modified:
   trunk/tests/src/org/jboss/test/messaging/jms/clustering/LargeClusterTest.java
Log:
test speedup


Modified: trunk/tests/src/org/jboss/test/messaging/jms/clustering/LargeClusterTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/clustering/LargeClusterTest.java	2007-08-08 16:22:23 UTC (rev 2982)
+++ trunk/tests/src/org/jboss/test/messaging/jms/clustering/LargeClusterTest.java	2007-08-08 20:38:27 UTC (rev 2983)
@@ -91,9 +91,17 @@
       assertTrue(view.contains(new Integer(6)));
       assertTrue(view.contains(new Integer(7)));
 
+      ServerManagement.kill(7);
+
+      if (!clusterEvent.viewChanged(30000))
+      {
+         fail("Did not receive view changed");
+      }
+
+      view = ServerManagement.getServer(0).getNodeIDView();
+      assertEquals(7, view.size());
+
       ServerManagement.removeNotificationListener(4, postOfficeObjectName, clusterEvent);
-
-      ServerManagement.kill(7);
    }
 
    /**
@@ -105,6 +113,8 @@
       // By this time, after running setUp(), we should have an already formed cluster of seven
       // nodes
 
+     
+
       Set view = ServerManagement.getServer(0).getNodeIDView();
 
       assertEquals(7, view.size());
@@ -249,6 +259,8 @@
       // We get the first node to re-join
 
       ServerManagement.start(0, "all", false);
+      ServerManagement.deployQueue("testDistributedQueue", 0);
+      ServerManagement.deployTopic("testDistributedTopic", 0);
 
       if (!clusterEvent.viewChanged(30000))
       {