diff options
| author | Gordon Sim <gsim@apache.org> | 2007-02-21 16:49:27 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-02-21 16:49:27 +0000 |
| commit | 2c4fdf9d81d32dd5c319714a86d3ab9ab5a6664e (patch) | |
| tree | 05cff3455d2c3dd97eafaa76ce92bc1d5c908411 /python/qpid | |
| parent | be9a95607d8e831e8f7c5802828afe677c798b93 (diff) | |
| download | qpid-python-2c4fdf9d81d32dd5c319714a86d3ab9ab5a6664e.tar.gz | |
Fixed bug in references where map wasn't qualified in close
Attach reference to transfer, as it will be deleted on close
Altered tests to get reference from the message on the queue rather than looking them up from channel as they are already gone there
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510096 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid')
| -rw-r--r-- | python/qpid/client.py | 2 | ||||
| -rw-r--r-- | python/qpid/reference.py | 2 |
2 files changed, 3 insertions, 1 deletions
diff --git a/python/qpid/client.py b/python/qpid/client.py index e14166c885..f6a540c7ec 100644 --- a/python/qpid/client.py +++ b/python/qpid/client.py @@ -111,6 +111,8 @@ class ClientDelegate(Delegate): self.client.started.set() def message_transfer(self, ch, msg): + if isinstance(msg.body, ReferenceId): + msg.reference = ch.references.get(msg.body.id) self.client.queue(msg.destination).put(msg) def message_open(self, ch, msg): diff --git a/python/qpid/reference.py b/python/qpid/reference.py index d357560390..48ecb67656 100644 --- a/python/qpid/reference.py +++ b/python/qpid/reference.py @@ -111,7 +111,7 @@ class References: self.get(id).close() self.lock.acquire() try: - del map[id] + self.map.pop(id) finally: self.lock.release() |