diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2008-06-16 23:20:52 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2008-06-16 23:20:52 +0000 |
| commit | ead2afe07e0d0b3ba383cca4ea77177218b4d080 (patch) | |
| tree | 25603c8725195cb179a6ff237923383bcf968b97 | |
| parent | 0f533c4a72b6224f4e01f4bbef996b5579c9fd50 (diff) | |
| download | qpid-python-ead2afe07e0d0b3ba383cca4ea77177218b4d080.tar.gz | |
add enough to the server delegate to permit java clients to connect
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@668343 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/python/qpid/delegates.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/qpid/python/qpid/delegates.py b/qpid/python/qpid/delegates.py index a284fb3b59..69b93e73dc 100644 --- a/qpid/python/qpid/delegates.py +++ b/qpid/python/qpid/delegates.py @@ -80,6 +80,9 @@ class Delegate: def session_detached(self, ch, d): self.connection.detach(d.name, ch) + def session_request_timeout(self, ch, rt): + ch.session_timeout(rt.timeout); + def session_command_point(self, ch, cp): ssn = ch.session ssn.receiver.next_id = cp.command_id @@ -112,10 +115,10 @@ class Server(Delegate): def start(self): self.connection.read_header() self.connection.write_header(self.spec.major, self.spec.minor) - connection.Channel(self.connection, 0).connection_start() + connection.Channel(self.connection, 0).connection_start(mechanisms=["ANONYMOUS"]) def connection_start_ok(self, ch, start_ok): - ch.connection_tune() + ch.connection_tune(channel_max=65535) def connection_tune_ok(self, ch, tune_ok): pass |