diff options
| author | Gordon Sim <gsim@apache.org> | 2007-02-12 15:15:25 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-02-12 15:15:25 +0000 |
| commit | cec1521f9e022bf695dbeddf8ea9a1769dca9f94 (patch) | |
| tree | 7556aa256be882bf98a79afb6b39999a3a5040d9 /python/qpid/client.py | |
| parent | 84a9b8a8f8b68b73db988943441410a51f6bc860 (diff) | |
| download | qpid-python-cec1521f9e022bf695dbeddf8ea9a1769dca9f94.tar.gz | |
* qpid/client.py - altered handling of transfer for references,
add the transfer to queue as before and require
client to look up the reference themselves. this
lets application access the other transfer fields
* tests/message.py - added some more tests for references
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@506477 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/client.py')
| -rw-r--r-- | python/qpid/client.py | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/python/qpid/client.py b/python/qpid/client.py index ed7dbca5d2..e14166c885 100644 --- a/python/qpid/client.py +++ b/python/qpid/client.py @@ -111,10 +111,7 @@ class ClientDelegate(Delegate): self.client.started.set() def message_transfer(self, ch, msg): - if isinstance(msg.body, ReferenceId): - self.client.queue(msg.destination).put(ch.references.get(msg.body.id)) - else: - self.client.queue(msg.destination).put(msg) + self.client.queue(msg.destination).put(msg) def message_open(self, ch, msg): ch.references.open(msg.reference) |