summaryrefslogtreecommitdiff
path: root/python/qpid/message.py
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2007-03-21 02:03:49 +0000
committerAlan Conway <aconway@apache.org>2007-03-21 02:03:49 +0000
commit862b354f6f777314cd4013f5cbd5aaf0003808d7 (patch)
tree722127acd578fec6cadc5b7ab0f0d864388342ae /python/qpid/message.py
parentae01787ce90ee7cd1303ce7769328cd242e00f6e (diff)
downloadqpid-python-862b354f6f777314cd4013f5cbd5aaf0003808d7.tar.gz
* python/qpid/*.py:: apply 0-9 changes missed by merge.
* python/cpp_failing_0-9.txt: update tests to refer to tess_0-9 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@520704 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/message.py')
-rw-r--r--python/qpid/message.py9
1 files changed, 6 insertions, 3 deletions
diff --git a/python/qpid/message.py b/python/qpid/message.py
index 29c8654937..f80293180e 100644
--- a/python/qpid/message.py
+++ b/python/qpid/message.py
@@ -47,9 +47,12 @@ class Message:
else:
for r in self.method.responses:
if attr == r.name:
- result = lambda *args, **kwargs: \
- self.channel.respond(Method(r, r.arguments(*args, **kwargs)),
- self.frame)
+ def respond(*args, **kwargs):
+ batch=0
+ if kwargs.has_key("batchoffset"):
+ batch=kwargs.pop("batchoffset")
+ self.channel.respond(Method(r, r.arguments(*args, **kwargs)), batch, self.frame)
+ result = respond
break
else:
raise AttributeError(attr)