summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2007-10-09 10:48:25 +0000
committerRobert Godfrey <rgodfrey@apache.org>2007-10-09 10:48:25 +0000
commitc43a4d0bffd5cfba569d5264aab284b1d6c653ae (patch)
tree8e09fbce168eefb7ab52f5bb9378a740c9917fb0
parentdda4016b8aa7b6cb2fb93ef5edb647e11f2490cd (diff)
downloadqpid-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.java13
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);