[hornetq-commits] JBoss hornetq SVN: r9115 - trunk/tests/src/org/hornetq/tests/integration/cluster/distribution.

[do-not-reply at jboss.org]

Author: timfox
Date: 2010-04-14 10:29:22 -0400 (Wed, 14 Apr 2010)
New Revision: 9115

Modified:
   trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/MessageRedistributionTest.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-359

Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/MessageRedistributionTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/MessageRedistributionTest.java	2010-04-14 13:03:49 UTC (rev 9114)
+++ trunk/tests/src/org/hornetq/tests/integration/cluster/distribution/MessageRedistributionTest.java	2010-04-14 14:29:22 UTC (rev 9115)
@@ -595,7 +595,44 @@
 
       verifyReceiveAll(QueueImpl.REDISTRIBUTOR_BATCH_SIZE * 2, 1);
    }
+   
+   /*
+    * Start one node with no consumers and send some messages
+    * Start another node add a consumer and verify all messages are redistribute
+    * https://jira.jboss.org/jira/browse/HORNETQ-359
+    */
+   public void testRedistributionWhenNewNodeIsAddedWithConsumer() throws Exception
+   {
+      setupCluster(false);
 
+      startServers(0);
+
+      setupSessionFactory(0, isNetty());
+      
+      setupSessionFactory(1, isNetty());
+      setupSessionFactory(2, isNetty());
+
+      createQueue(0, "queues.testaddress", "queue0", null, false);
+      
+      waitForBindings(0, "queues.testaddress", 1, 0, true);
+      
+      send(0, "queues.testaddress", 20, false, null);
+      
+      //Now bring up node 1
+      
+      startServers(1);
+      
+      createQueue(1, "queues.testaddress", "queue0", null, false);
+      
+      waitForBindings(1, "queues.testaddress", 1, 0, true);
+      waitForBindings(0, "queues.testaddress", 1, 0, false);
+      
+      addConsumer(0, 1, "queue0", null);
+      
+      verifyReceiveAll(20, 0);
+      verifyNotReceive(0);
+   }
+
    protected void setupCluster(final boolean forwardWhenNoConsumers) throws Exception
    {
       setupClusterConnection("cluster0", "queues", forwardWhenNoConsumers, 1, isNetty(), 0, 1, 2);