diff options
author | Martin Ritchie <ritchiem@apache.org> | 2007-10-10 17:14:53 +0000 |
---|---|---|
committer | Martin Ritchie <ritchiem@apache.org> | 2007-10-10 17:14:53 +0000 |
commit | 004bbb06f033571ff5461618113917a915efced4 (patch) | |
tree | c6dcad42c3af2663cb3d1aac852f64349a84f25c | |
parent | 1176b9654e4dc089eeedd32f791d910048c68730 (diff) | |
download | qpid-python-004bbb06f033571ff5461618113917a915efced4.tar.gz |
QPID-631 : Patch provided by Aidan Skinner to address the errors in the MessageRequeueTest.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583546 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | java/client/src/test/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java b/java/client/src/test/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java index a297011acd..8d7645c1fd 100644 --- a/java/client/src/test/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java +++ b/java/client/src/test/java/org/apache/qpid/test/unit/close/MessageRequeueTest.java @@ -178,7 +178,7 @@ public class MessageRequeueTest extends TestCase /** multiple consumers * Based on code subbmitted by client FT-304 */ - public void testTwoCompetingConsumers() + public void testCompetingConsumers() { Consumer c1 = new Consumer(); Consumer c2 = new Consumer(); @@ -193,7 +193,7 @@ public class MessageRequeueTest extends TestCase t1.start(); t2.start(); t3.start(); - // t4.start(); + t4.start(); try { @@ -224,7 +224,7 @@ public class MessageRequeueTest extends TestCase { if ((b == 0) && (index != 0)) // delivery tag of zero shouldn't exist (and we don't have msg 0) { - _logger.error("Index: " + index + " was not received."); + fail("Index: " + index + " was not received."); list.append(" "); list.append(index); list.append(":"); @@ -236,7 +236,7 @@ public class MessageRequeueTest extends TestCase } assertEquals(list.toString() + "-" + numTestMessages + "-" + totalConsumed, 0, failed); - assertEquals("number of consumed messages does not match initial data", numTestMessages, totalConsumed); + assertTrue("number of consumed messages does not match initial data: " + totalConsumed, numTestMessages <= totalConsumed); passed = true; } |