From 5d8e8d39e1e5e13d0753c53a8095f075895d01a1 Mon Sep 17 00:00:00 2001 From: Andrew Stitcher Date: Tue, 13 Feb 2007 21:52:30 +0000 Subject: r1111@fuschia: andrew | 2007-02-09 15:51:10 +0000 Removed currently unused request tracking logic r1125@fuschia: andrew | 2007-02-13 21:51:30 +0000 Implemented receiveing batched Message.ok in c++ broker Implemented batched response frames in python client code git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@507249 13f79535-47bb-0310-9956-ffa450edef68 --- python/tests/message.py | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) (limited to 'python/tests') diff --git a/python/tests/message.py b/python/tests/message.py index d044d638e7..84219bfe25 100644 --- a/python/tests/message.py +++ b/python/tests/message.py @@ -384,16 +384,12 @@ class MessageTests(TestBase): self.assertEqual(reply.method.name, "ok") msg = self.client.queue(tag).get(timeout=1) self.assertEqual("Message %d" % i, msg.body) - # TODO: replace with below when we have batching - if(i in [11, 12, 13, 15, 17, 19]): + + if (i==13): + msg.ok(batchoffset=-2) + if(i in [15, 17, 19]): msg.ok() - #todo: when batching is available, test ack multiple - #if(i == 13): - # channel.message_ack(delivery_tag=reply.delivery_tag, multiple=True) - #if(i in [15, 17, 19]): - # channel.message_ack(delivery_tag=reply.delivery_tag) - reply = channel.message_get(no_ack=True, queue="test-get") self.assertEqual(reply.method.klass.name, "message") self.assertEqual(reply.method.name, "empty") -- cgit v1.2.1