diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2012-01-20 20:27:59 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2012-01-20 20:27:59 +0000 |
| commit | bcc3eec81fed2e1f0acd0019e055d7f47303696b (patch) | |
| tree | 9b6c6af1be3cfe3dc31f55e8c01a1db20d3cac01 /java/systests | |
| parent | 1a08c4097f7e18251f21ed0ea2a7660b24dface6 (diff) | |
| download | qpid-python-bcc3eec81fed2e1f0acd0019e055d7f47303696b.tar.gz | |
QPID-3774 : allow out of order completion of persistent enqueues / dequeues
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1234111 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/systests')
| -rw-r--r-- | java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java | 5 | ||||
| -rw-r--r-- | java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java | 2 |
2 files changed, 6 insertions, 1 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java b/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java index 12039caf25..e6461c8267 100644 --- a/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java +++ b/java/systests/src/main/java/org/apache/qpid/test/unit/ack/AcknowledgeTest.java @@ -70,6 +70,11 @@ public class AcknowledgeTest extends QpidBrokerTestCase // These should all end up being prefetched by session sendMessage(_consumerSession, _queue, 1); + if(!transacted) + { + ((AMQSession)_consumerSession).sync(); + } + assertEquals("Wrong number of messages on queue", 1, ((AMQSession) _consumerSession).getQueueDepth((AMQDestination) _queue)); } diff --git a/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java b/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java index d3d9cf2984..e948aaffb3 100644 --- a/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java +++ b/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java @@ -721,7 +721,7 @@ public class DurableSubscriptionTest extends QpidBrokerTestCase msg = session.createTextMessage("testResubscribeWithChangedSelectorAndRestart2"); msg.setBooleanProperty("Match", false); producer.send(msg); - + ((AMQSession)session).sync(); // should be 1 or 2 messages on queue now // (1 for the java broker due to use of server side selectors, and 2 for the cpp broker due to client side selectors only) AMQQueue queue = new AMQQueue("amq.topic", "clientid" + ":" + "testResubscribeWithChangedSelectorNoClose"); |