diff options
| author | Gordon Sim <gsim@apache.org> | 2016-05-12 11:30:07 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2016-05-12 11:30:07 +0000 |
| commit | 4a5ea2a86111da23263193247ad59d85fbf695f6 (patch) | |
| tree | 5f5cb5b042ac3f41b7ad1095ba7ffe60d1c29665 | |
| parent | 5fdd81bf916d0499b84c0c75f853eb710e35157f (diff) | |
| download | qpid-python-4a5ea2a86111da23263193247ad59d85fbf695f6.tar.gz | |
QPID-7259: delay adding transfers to completed set until we have verified queue is empty
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1743491 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/python/qpid_tests/broker_0_10/message.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/qpid/python/qpid_tests/broker_0_10/message.py b/qpid/python/qpid_tests/broker_0_10/message.py index 48853cf31b..481416824d 100644 --- a/qpid/python/qpid_tests/broker_0_10/message.py +++ b/qpid/python/qpid_tests/broker_0_10/message.py @@ -481,14 +481,17 @@ class MessageTests(TestBase010): session.message_flow(unit = session.credit_unit.byte, value = 0xFFFFFFFFL, destination = "c") #check that expected number were received q = session.incoming("c") + ids = [] for i in range(1, 6): msg = q.get(timeout = 1) - session.receiver._completed.add(msg.id)#TODO: this may be done automatically + ids.append(msg.id) self.assertDataEquals(session, msg, "Message %d" % i) self.assertEmpty(q) #acknowledge messages and check more are received #TODO: there may be a nicer way of doing this + for i in ids: + session.receiver._completed.add(i) session.channel.session_completed(session.receiver._completed) for i in range(6, 11): |