diff options
author | Robert Gemmell <robbie@apache.org> | 2011-11-11 10:18:43 +0000 |
---|---|---|
committer | Robert Gemmell <robbie@apache.org> | 2011-11-11 10:18:43 +0000 |
commit | 7f6fa1251db88c5546bf7fba973844512f025eb3 (patch) | |
tree | 6694f9699f82d1195d42d3cd2a2846e47b19fab0 /tests | |
parent | a1f730067b3be09080327ac05312eeb6da47297b (diff) | |
download | qpid-python-7f6fa1251db88c5546bf7fba973844512f025eb3.tar.gz |
QPID-3593: update python Priority Queue tests to use legal values for message priority, since the prior illegal values were preventing them running against the Java broker.
Applied patch by Andrew MacBean <andymacbean@gmail.com>
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1200802 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'tests')
-rw-r--r-- | tests/src/py/qpid_tests/broker_0_10/priority.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/tests/src/py/qpid_tests/broker_0_10/priority.py b/tests/src/py/qpid_tests/broker_0_10/priority.py index 6a60add97e..f99e908d76 100644 --- a/tests/src/py/qpid_tests/broker_0_10/priority.py +++ b/tests/src/py/qpid_tests/broker_0_10/priority.py @@ -77,13 +77,13 @@ class PriorityTests (Base): self.ssn.acknowledge(msg) def test_prioritised_delivery_1(self): - self.prioritised_delivery(priorities = [8,9,5,1,2,2,3,4,15,7,8,10,10,2], levels = 10) + self.prioritised_delivery(priorities = [8,9,5,1,2,2,3,4,9,7,8,9,9,2], levels = 10) def test_prioritised_delivery_with_alias(self): self.prioritised_delivery(priorities = [8,9,5,1,2,2,3,4,15,7,8,10,10,2], levels = 10, key="qpid.priorities") def test_prioritised_delivery_2(self): - self.prioritised_delivery(priorities = [8,9,5,1,2,2,3,4,15,7,8,10,10,2], levels = 5) + self.prioritised_delivery(priorities = [8,9,5,1,2,2,3,4,9,7,8,9,9,2], levels = 5) def test_fairshare_1(self): self.fairshare_delivery(priorities = [4,5,3,6,10,10,2,10,2,10,10,1,10,10,10,3,3,3,10,10,3,10,3,10,10,10,10,10,10,2,3]) @@ -98,7 +98,7 @@ class PriorityTests (Base): self.fairshare_delivery(priorities = [4,5,3,7,8,8,2,8,2,8,8,16,6,6,6,6,6,6,8,3,5,8,3,5,5,3,3,8,8,3,7,3,7,7,7,8,8,8,2,3], limits={7:0,6:4,5:3,4:2,3:2,2:2,1:2}, levels=8) def test_browsing(self): - priorities = [4,5,3,6,10,10,2,10,2,10,10,1,10,10,10,3,3,3,10,10,3,10,3,10,10,10,10,10,10,2,3] + priorities = [4,5,3,6,0,1,2,8,2,0,2,1,6,0,1,3,3,3,8,1,3,0,3,7,9,0,1,9,0,2,3] msgs = [Message(content=str(uuid4()), priority = p) for p in priorities] snd = self.ssn.sender("priority-queue; {create: sender, node: {x-declare:{arguments:{x-qpid-priorities:10}}}}", durable=self.durable()) @@ -146,7 +146,7 @@ class PriorityTests (Base): self.ring_queue_check([Message(content=seq.next(), priority = p) for p in priorities]) def test_requeue(self): - priorities = [4,5,3,6,10,10,2,10,2,10,10,1,10,10,10,3,3,3,10,10,3,10,3,10,10,10,10,10,10,2,3] + priorities = [4,5,3,6,9,9,2,9,2,9,9,1,9,9,9,3,3,3,9,9,3,9,3,9,9,9,9,9,9,2,3] msgs = [Message(content=str(uuid4()), priority = p) for p in priorities] snd = self.ssn.sender("priority-queue; {create: sender, delete: receiver, node: {x-declare:{arguments:{x-qpid-priorities:10}}}}", |