diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2007-08-10 15:55:16 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2007-08-10 15:55:16 +0000 |
| commit | 01652ef4ec4d7a92bfdcf677c27fb28968398bc6 (patch) | |
| tree | 495a8d994def30a30512beaf4077643c41cff332 /python/qpid/client.py | |
| parent | 6577b14632d81c15482cb0793e01166cdb28eaff (diff) | |
| download | qpid-python-01652ef4ec4d7a92bfdcf677c27fb28968398bc6.tar.gz | |
added support for unpacked structs and execution.result
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@564637 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/client.py')
| -rw-r--r-- | python/qpid/client.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/python/qpid/client.py b/python/qpid/client.py index f1800204db..3efd79c389 100644 --- a/python/qpid/client.py +++ b/python/qpid/client.py @@ -110,7 +110,7 @@ class ClientDelegate(Delegate): #todo: just override the params, i.e. don't require them # all to be included in tune_params msg.tune_ok(**self.client.tune_params) - else: + else: msg.tune_ok(*msg.frame.args) self.client.started.set() @@ -143,6 +143,10 @@ class ClientDelegate(Delegate): def execution_complete(self, ch, msg): ch.completion.complete(msg.cumulative_execution_mark) + def execution_result(self, ch, msg): + future = ch.futures[msg.command_id] + future.put_response(ch, msg.data) + def close(self, reason): self.client.closed = True self.client.reason = reason |