diff options
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) |