diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2007-09-26 10:45:21 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2007-09-26 10:45:21 +0000 |
| commit | 54a95aac99030c14f4ba2a26163e34117e7e21ff (patch) | |
| tree | a3bdfd6cd103edbf4823693ef758d294fa0c0b11 /java/client/src/test | |
| parent | 8253fe4a73d856ef137edab176da8402f1dd5332 (diff) | |
| download | qpid-python-54a95aac99030c14f4ba2a26163e34117e7e21ff.tar.gz | |
Updated TransportConnection to synchronize around the creation/destruction of VM Brokers. I had observed a ConcurrentModificationException in the KillAllVMBrokers().
This isn't good this suggests that the tests are overlapping. This fix won't address that problem but will stop any CModifications occuring. If there is test setup/teardown overlapping we should now see tests failing because the VM broker isn't there.
Potentially addresses VM issues in QPID-596
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@579577 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src/test')
| -rw-r--r-- | java/client/src/test/java/org/apache/qpid/test/unit/transacted/CommitRollbackTest.java | 7 |
1 files changed, 7 insertions, 0 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 1a45773907..6db27d6be0 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 @@ -434,6 +434,13 @@ public class CommitRollbackTest extends TestCase verifyMessages(_consumer.receive(1000)); } + /** + * This test sends two messages receives on of them but doesn't ack it. + * The consumer is then closed + * the first message should be returned as redelivered. + * the second message should be delivered normally. + * @throws Exception + */ public void testSend2ThenCloseAfter1andTryAgain() throws Exception { assertTrue("session is not transacted", _session.getTransacted()); |