From 4a5ea2a86111da23263193247ad59d85fbf695f6 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 12 May 2016 11:30:07 +0000 Subject: 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 --- qpid/python/qpid_tests/broker_0_10/message.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'qpid/python') 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): -- cgit v1.2.1