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