Merged revisions 496593 via svnmerge from

https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9

........
  r496593 | rhs | 2007-01-16 00:28:25 -0500 (Tue, 16 Jan 2007) | 1 line
  
  0-9 request/response framing for python
........


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@519129 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 30 insertions, 0 deletions

diff --git a/qpid/python/server b/qpid/python/server
new file mode 100755
index 0000000000..4204bc8515
--- /dev/null
+++ b/qpid/python/server
@@ -0,0 +1,30 @@
+#!/usr/bin/env python
+from qpid import spec
+from qpid.connection import Connection, listen
+from qpid.delegate import Delegate
+from qpid.peer import Peer
+
+class Server(Delegate):
+
+  def connection_open(self, ch, msg):
+    msg.open_ok()
+
+  def channel_open(self, ch, msg):
+    print "channel %s open" % ch.id
+    msg.open_ok()
+
+  def message_transfer(self, ch, msg):
+    print msg.body
+    msg.ok()
+
+
+spec = spec.load("../specs/amqp.0-9.xml")
+
+for io in listen("0.0.0.0", 5672):
+  c = Connection(io, spec)
+  p = Peer(c, Server())
+  c.tini()
+  p.start()
+  ch = p.channel(0)
+  ch.connection_start()
+  ch.connection_tune()