summaryrefslogtreecommitdiff
path: root/python/qpid/session.py
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2009-08-21 22:21:49 +0000
committerRafael H. Schloming <rhs@apache.org>2009-08-21 22:21:49 +0000
commit5f1d73e5cc7bd32fb0c3bfe5a296138cc7ffa30b (patch)
tree724cf3cf0711bb3c12c89fd0deea8a2446898582 /python/qpid/session.py
parent2ad1a5da3732b280d9b780313969bef4da05f113 (diff)
downloadqpid-python-5f1d73e5cc7bd32fb0c3bfe5a296138cc7ffa30b.tar.gz
fixed some more channel attribute errors; eliminated most uses of catchup in favor of waiting on semantically meaningful predicates; fixed Serial.__cmp__ to check the type of the other object
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@806734 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/session.py')
-rw-r--r--python/qpid/session.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/python/qpid/session.py b/python/qpid/session.py
index 071d4dc817..2f1bd81bd4 100644
--- a/python/qpid/session.py
+++ b/python/qpid/session.py
@@ -244,13 +244,16 @@ class Sender:
self._completed = RangedSet()
def send(self, cmd):
+ ch = self.session.channel
+ if ch is None:
+ raise SessionDetached()
cmd.id = self.next_id
self.next_id += 1
if self.session.send_id:
self.session.send_id = False
- self.session.channel.session_command_point(cmd.id, 0)
+ ch.session_command_point(cmd.id, 0)
self.commands.append(cmd)
- self.session.channel.connection.write_op(cmd)
+ ch.connection.write_op(cmd)
def completed(self, commands):
idx = 0