summaryrefslogtreecommitdiff
path: root/python/qpid/delegates.py
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-04-22 16:11:34 +0000
committerRafael H. Schloming <rhs@apache.org>2008-04-22 16:11:34 +0000
commite06aa805cfe24b8edf619a6a535883f94589ac35 (patch)
tree4b886461816ca97127aae8a9639ddad74d77bd46 /python/qpid/delegates.py
parent61959e29ee69f9cebb61b845272eededaec6f11e (diff)
downloadqpid-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.py10
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()