Author: rhs
Date: Mon Jun 16 16:20:52 2008
New Revision: 668343
URL: http://svn.apache.org/viewvc?rev=668343&view=rev
Log:
add enough to the server delegate to permit java clients to connect
Modified:
incubator/qpid/trunk/qpid/python/qpid/delegates.py
Modified: incubator/qpid/trunk/qpid/python/qpid/delegates.py
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/qpid/delegates.py?rev=668343&r1=668342&r2=668343&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/qpid/delegates.py (original)
+++ incubator/qpid/trunk/qpid/python/qpid/delegates.py Mon Jun 16 16:20:52 2008
@@ -80,6 +80,9 @@
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 @@
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
