diff options
| author | Ted Ross <tross@apache.org> | 2009-11-11 17:33:33 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2009-11-11 17:33:33 +0000 |
| commit | ea3ed931fde51d95416c8f25520908f170ef716b (patch) | |
| tree | 1736b3e06ef3391b243b905b883792a40b3eba2d /python/qpid/connection.py | |
| parent | fe2b5f5849574d7281c16b6ba066ced2d25184e2 (diff) | |
| download | qpid-python-ea3ed931fde51d95416c8f25520908f170ef716b.tar.gz | |
Added full SASL authentication and security layer for the Python client.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@834975 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qpid/connection.py')
| -rw-r--r-- | python/qpid/connection.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/python/qpid/connection.py b/python/qpid/connection.py index 680f8f62e3..18eeb99de8 100644 --- a/python/qpid/connection.py +++ b/python/qpid/connection.py @@ -65,6 +65,7 @@ class Connection(Framer): self.thread.setDaemon(True) self.channel_max = 65535 + self.user_id = None self.op_enc = OpEncoder() self.seg_enc = SegmentEncoder() @@ -156,6 +157,8 @@ class Connection(Framer): while not self.closed: try: data = self.sock.recv(64*1024) + if self.security_layer_rx and data: + status, data = self.security_layer_rx.decode(data) if not data: self.detach_all() break |