From 70a2a643f61aa1450fcdc0f754870301e29b3553 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Mon, 16 Jun 2008 23:20:52 +0000 Subject: add enough to the server delegate to permit java clients to connect git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@668343 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/delegates.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'python/qpid') diff --git a/python/qpid/delegates.py b/python/qpid/delegates.py index a284fb3b59..69b93e73dc 100644 --- a/python/qpid/delegates.py +++ b/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 -- cgit v1.2.1