Author: orudyy
Date: Thu Apr 21 15:33:21 2016
New Revision: 1740341
URL: http://svn.apache.org/viewvc?rev=1740341&view=rev
Log:
QPID-7222: Make python test
qpid_tests.broker_0_10.message.MessageTests.test_release_order to fetch
explicitly required number of messages before sending accept/release in order
to make sure that released messages are not resend back by the broker
Modified:
qpid/trunk/qpid/python/qpid_tests/broker_0_10/message.py
Modified: qpid/trunk/qpid/python/qpid_tests/broker_0_10/message.py
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid_tests/broker_0_10/message.py?rev=1740341&r1=1740340&r2=1740341&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid_tests/broker_0_10/message.py (original)
+++ qpid/trunk/qpid/python/qpid_tests/broker_0_10/message.py Thu Apr 21
15:33:21 2016
@@ -1023,9 +1023,15 @@ class MessageTests(TestBase010):
session.message_flow(unit = session.credit_unit.byte, value =
0xFFFFFFFFL, destination = "a")
session.message_flow(unit = session.credit_unit.message, value = 10,
destination = "a")
+ # receive all messages into list
+ messages = [];
for i in range(1, 11):
msg = a.get(timeout = 1)
self.assertEquals("message-%d" % (i), msg.body)
+ messages.append(msg)
+
+ # accept/release received messages
+ for i, msg in enumerate(messages, start=1):
if (i % 2):
#accept all odd messages
session.message_accept(RangedSet(msg.id))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
