summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2012-02-21 10:19:37 +0000
committerRobert Godfrey <rgodfrey@apache.org>2012-02-21 10:19:37 +0000
commitd08b4d647ff8a995b0d85f0d5c034ab8a1de7309 (patch)
tree045ef7663218a849f4435310efdc4211fd45a5af
parentbad3e9476fc34f950c2b371fce3ea7c532b9f46a (diff)
downloadqpid-python-d08b4d647ff8a995b0d85f0d5c034ab8a1de7309.tar.gz
QPID-3861 : Race condition in the python msg group test using a queue browser
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1291693 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--tests/src/py/qpid_tests/broker_0_10/msg_groups.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/tests/src/py/qpid_tests/broker_0_10/msg_groups.py b/tests/src/py/qpid_tests/broker_0_10/msg_groups.py
index 938d3b3ee2..18fb0a61a3 100644
--- a/tests/src/py/qpid_tests/broker_0_10/msg_groups.py
+++ b/tests/src/py/qpid_tests/broker_0_10/msg_groups.py
@@ -193,6 +193,10 @@ class MultiConsumerMsgGroupTests(Base):
s2 = self.setup_session()
b1 = s2.receiver("msg-group-q; {mode: browse}", options={"capacity":0})
+ m2 = b1.fetch(0);
+ assert m2.properties['THE-GROUP'] == 'A'
+ assert m2.content['index'] == 0
+
# C1 should acquire A-0
m1 = c1.fetch(0);
@@ -202,10 +206,6 @@ class MultiConsumerMsgGroupTests(Base):
## Queue = A-0, B-1, A-2, b-3, C-4
## Owners= ^C1, ---, +C1, ---, ---
- m2 = b1.fetch(0);
- assert m2.properties['THE-GROUP'] == 'A'
- assert m2.content['index'] == 0
-
m2 = b1.fetch(0)
assert m2.properties['THE-GROUP'] == 'B'
assert m2.content['index'] == 1