From acc494abc20309733d6884d9a524a2334bddd967 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Mon, 24 Aug 2009 13:50:20 +0000 Subject: candidate fix for messages sent on unlinked senders git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@807217 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/messaging.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) (limited to 'python/qpid/messaging.py') diff --git a/python/qpid/messaging.py b/python/qpid/messaging.py index d2769dde4c..47f7e560c5 100644 --- a/python/qpid/messaging.py +++ b/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: -- cgit v1.2.1