diff options
author | Rafael H. Schloming <rhs@apache.org> | 2008-04-22 16:11:34 +0000 |
---|---|---|
committer | Rafael H. Schloming <rhs@apache.org> | 2008-04-22 16:11:34 +0000 |
commit | e06aa805cfe24b8edf619a6a535883f94589ac35 (patch) | |
tree | 4b886461816ca97127aae8a9639ddad74d77bd46 /python/qpid/delegates.py | |
parent | 61959e29ee69f9cebb61b845272eededaec6f11e (diff) | |
download | qpid-python-e06aa805cfe24b8edf619a6a535883f94589ac35.tar.gz |
QPID-947: update cpp and python management to 0-10 final
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@650565 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/delegates.py')
-rw-r--r-- | python/qpid/delegates.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/python/qpid/delegates.py b/python/qpid/delegates.py index 9df2cd04bd..c958313671 100644 --- a/python/qpid/delegates.py +++ b/python/qpid/delegates.py @@ -17,7 +17,7 @@ # under the License. # -import os, connection010, session +import os, connection, session from util import notify from datatypes import RangedSet from logging import getLogger @@ -35,7 +35,7 @@ class Delegate: def received(self, seg): ssn = self.connection.attached.get(seg.channel) if ssn is None: - ch = connection010.Channel(self.connection, seg.channel) + ch = connection.Channel(self.connection, seg.channel) else: ch = ssn.channel @@ -61,9 +61,9 @@ class Delegate: try: self.connection.attach(a.name, ch, self.delegate, a.force) ch.session_attached(a.name) - except connection010.ChannelBusy: + except connection.ChannelBusy: ch.session_detached(a.name) - except connection010.SessionBusy: + except connection.SessionBusy: ch.session_detached(a.name) def session_attached(self, ch, a): @@ -105,7 +105,7 @@ class Server(Delegate): def start(self): self.connection.read_header() self.connection.write_header(self.spec.major, self.spec.minor) - connection010.Channel(self.connection, 0).connection_start() + connection.Channel(self.connection, 0).connection_start() def connection_start_ok(self, ch, start_ok): ch.connection_tune() |