diff options
| author | Robert Gemmell <robbie@apache.org> | 2012-02-03 10:32:30 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2012-02-03 10:32:30 +0000 |
| commit | fe2aa8295f87d02f71e96162daaf36f76a4efcf3 (patch) | |
| tree | b135ddf6b919d76db3bbce41a7f0e16fbbc67574 /java | |
| parent | 39043f2451353c7f3fd2a427d8209c9d1043e78c (diff) | |
| download | qpid-python-fe2aa8295f87d02f71e96162daaf36f76a4efcf3.tar.gz | |
QPID-3781: fix system test MaxDeliveryCountTest.testAsynchronousDupsOkSession by ensuring the queue depth check syncs first
Applied patch from Andrew MacBean <andymacbean@gmail.com> and Oleksandr Rudyy<orudyy@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1240065 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java b/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java index 2c6f0f911b..fa0fe7e0b5 100644 --- a/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java +++ b/java/systests/src/main/java/org/apache/qpid/test/unit/client/MaxDeliveryCountTest.java @@ -298,7 +298,7 @@ public class MaxDeliveryCountTest extends QpidBrokerTestCase consumer.close(); //check the source queue is now empty - assertEquals("The queue should have 0 msgs left", 0, ((AMQSession<?,?>) clientSession).getQueueDepth(checkQueue)); + assertEquals("The queue should have 0 msgs left", 0, ((AMQSession<?,?>) clientSession).getQueueDepth(checkQueue, true)); //check the DLQ has the required number of rejected-without-requeue messages verifyDLQdepth(redeliverMsgs.size(), clientSession, durableSub); @@ -341,7 +341,7 @@ public class MaxDeliveryCountTest extends QpidBrokerTestCase } assertEquals("The DLQ should have " + expected + " msgs on it", expected, - ((AMQSession<?,?>) clientSession).getQueueDepth(checkQueueDLQ)); + ((AMQSession<?,?>) clientSession).getQueueDepth(checkQueueDLQ, true)); } private void verifyDLQcontent(Connection clientConnection, List<Integer> redeliverMsgs, String destName, boolean durableSub) throws JMSException |