diff options
author | Alan Conway <aconway@apache.org> | 2007-03-21 02:03:49 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2007-03-21 02:03:49 +0000 |
commit | 862b354f6f777314cd4013f5cbd5aaf0003808d7 (patch) | |
tree | 722127acd578fec6cadc5b7ab0f0d864388342ae /python/qpid/message.py | |
parent | ae01787ce90ee7cd1303ce7769328cd242e00f6e (diff) | |
download | qpid-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.py | 9 |
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) |