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();
}