diff options
author | Robert Godfrey <rgodfrey@apache.org> | 2007-10-09 10:48:25 +0000 |
---|---|---|
committer | Robert Godfrey <rgodfrey@apache.org> | 2007-10-09 10:48:25 +0000 |
commit | c43a4d0bffd5cfba569d5264aab284b1d6c653ae (patch) | |
tree | 8e09fbce168eefb7ab52f5bb9378a740c9917fb0 | |
parent | dda4016b8aa7b6cb2fb93ef5edb647e11f2490cd (diff) | |
download | qpid-python-c43a4d0bffd5cfba569d5264aab284b1d6c653ae.tar.gz |
QPID-625 : Fix commit rollback test to prevent failures caused by incorrect assertions in the test
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@583105 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r-- | java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java b/java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java index 3d5a1096b4..a4c016916e 100644 --- a/java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java +++ b/java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java @@ -481,9 +481,16 @@ public class CommitRollbackTest extends TestCase assertEquals("2", ((TextMessage) result).getText()); } - result = _consumer.receive(1000); - assertNotNull("test message was consumed and rolled back, but is gone", result); - assertTrue("Messasge is not marked as redelivered" + result, result.getJMSRedelivered()); + Message result2 = _consumer.receive(1000); + assertNotNull("test message was consumed and rolled back, but is gone", result2); + + // if this is message 1 then it should be marked as redelivered + if("1".equals(((TextMessage) result2).getText())) + { + assertTrue("Messasge is not marked as redelivered" + result2, result2.getJMSRedelivered()); + } + + assertNotSame("Messages should not have the same content",((TextMessage) result2).getText(), ((TextMessage) result).getText() ); result = _consumer.receive(1000); assertNull("test message should be null:" + result, result); |