diff options
| author | Andrew Stitcher <astitcher@apache.org> | 2007-02-13 21:52:30 +0000 |
|---|---|---|
| committer | Andrew Stitcher <astitcher@apache.org> | 2007-02-13 21:52:30 +0000 |
| commit | 5d8e8d39e1e5e13d0753c53a8095f075895d01a1 (patch) | |
| tree | 727d30e03ae1679827779560a32f11c12f32d4a5 /python/tests | |
| parent | 9517deedff9691dbe3429b0b917dfd4208b0b1b8 (diff) | |
| download | qpid-python-5d8e8d39e1e5e13d0753c53a8095f075895d01a1.tar.gz | |
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
Diffstat (limited to 'python/tests')
| -rw-r--r-- | python/tests/message.py | 12 |
1 files changed, 4 insertions, 8 deletions
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") |