diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2009-08-24 13:50:20 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2009-08-24 13:50:20 +0000 |
| commit | fa7b6466c938ee941881b46246100dffa6e576a0 (patch) | |
| tree | cefb63d73e5533695fbb1c4344295c421ffd4fa9 /qpid/python | |
| parent | 2720aff4ca7262a0b2ef22b17629fa42f84ba0de (diff) | |
| download | qpid-python-fa7b6466c938ee941881b46246100dffa6e576a0.tar.gz | |
candidate fix for messages sent on unlinked senders
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@807217 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python')
| -rw-r--r-- | qpid/python/qpid/messaging.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/qpid/python/qpid/messaging.py b/qpid/python/qpid/messaging.py index d2769dde4c..47f7e560c5 100644 --- a/qpid/python/qpid/messaging.py +++ b/qpid/python/qpid/messaging.py @@ -1006,6 +1006,9 @@ class Driver(Lockable): if snd.closed: del self._attachments[snd] + return None + else: + return _snd def link_in(self, rcv): _ssn = self._attachments[rcv.session] @@ -1037,6 +1040,9 @@ class Driver(Lockable): _ssn.sync() del self._attachments[rcv] rcv.closed = True + return None + else: + return _rcv def process(self, ssn): if ssn.closing: return @@ -1113,7 +1119,7 @@ class Driver(Lockable): def grant(self, rcv): _ssn = self._attachments[rcv.session] - _rcv = self._attachments[rcv] + _rcv = self.link_in(rcv) if rcv.granted is UNLIMITED: if rcv.impending is UNLIMITED: @@ -1149,7 +1155,7 @@ class Driver(Lockable): def send(self, snd, msg): _ssn = self._attachments[snd.session] - _snd = self._attachments[snd] + _snd = self.link_out(snd) # XXX: what if subject is specified for a normal queue? if _snd._routing_key is None: |