diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2010-02-26 00:02:33 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2010-02-26 00:02:33 +0000 |
| commit | 5b98d7bb9d34362eda787829c8c308c8bd279ea1 (patch) | |
| tree | 7e1ea543dc743d4e38d6f38aab6e1427df6f1c5c /python/qpid/messaging/endpoints.py | |
| parent | e7b97eac85d94d739cba9d9a324e9c7319271278 (diff) | |
| download | qpid-python-5b98d7bb9d34362eda787829c8c308c8bd279ea1.tar.gz | |
split engine into a separate class
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@916499 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/messaging/endpoints.py')
| -rw-r--r-- | python/qpid/messaging/endpoints.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/python/qpid/messaging/endpoints.py b/python/qpid/messaging/endpoints.py index 596866de66..004cee5f88 100644 --- a/python/qpid/messaging/endpoints.py +++ b/python/qpid/messaging/endpoints.py @@ -94,6 +94,7 @@ class Connection: self.session_counter = 0 self.sessions = {} self._connected = False + self._transport_connected = False self._lock = RLock() self._condition = Condition(self._lock) self._waiter = Waiter(self._condition) @@ -157,7 +158,7 @@ class Connection: """ self._connected = True self._wakeup() - self._ewait(lambda: self._driver._connected and not self._unlinked(), + self._ewait(lambda: self._transport_connected and not self._unlinked(), exc=ConnectError) def _unlinked(self): @@ -173,7 +174,7 @@ class Connection: """ self._connected = False self._wakeup() - self._ewait(lambda: not self._driver._connected) + self._ewait(lambda: not self._transport_connected) @synchronized def connected(self): |