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

[do-not-reply at jboss.org]

Author: ataylor
Date: 2009-11-11 08:46:28 -0500 (Wed, 11 Nov 2009)
New Revision: 8259

Modified:
   trunk/tests/src/org/hornetq/tests/integration/cluster/failover/ReplicatedDistrubtionTest.java
Log:
test fix

Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/failover/ReplicatedDistrubtionTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/cluster/failover/ReplicatedDistrubtionTest.java	2009-11-11 09:37:55 UTC (rev 8258)
+++ trunk/tests/src/org/hornetq/tests/integration/cluster/failover/ReplicatedDistrubtionTest.java	2009-11-11 13:46:28 UTC (rev 8259)
@@ -69,7 +69,7 @@
       sessionThree.start();
 
       waitForBindings(3, "test.SomeAddress", 1, 1, true);
-
+      waitForBindings(1, "test.SomeAddress", 1, 1, false);
       try
       {
          ClientProducer producer = sessionOne.createProducer(ADDRESS);
@@ -94,11 +94,8 @@
 
             int received = (Integer)msg.getObjectProperty(new SimpleString("key"));
 
-            if (i != received)
-            {
-               // Shouldn't this be a failure?
-               System.out.println(i + "!=" + received);
-            }
+            assertEquals(i, received);
+
             msg.acknowledge();
          }
 
@@ -110,6 +107,7 @@
          // Redistribution may loose messages between the nodes.
          Thread.sleep(500);
 
+
          fail(sessionThree);
 
          // sessionThree.close();
@@ -132,11 +130,8 @@
 
             int received = (Integer)msg.getObjectProperty(new SimpleString("key"));
 
-            if (i != received)
-            {
-               // Shouldn't this be a failure?
-               System.out.println(i + "!=" + received);
-            }
+            assertEquals(i, received);
+
             msg.acknowledge();
          }