added incoming queues for messages; altered session dispatch to send entire assembly to a single handler; added logging switch for hello-010-world

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

1 files changed, 6 insertions, 0 deletions

diff --git a/qpid/python/server010 b/qpid/python/server010
index b0e13d1e9f..6d89ee5ea0 100755
--- a/qpid/python/server010
+++ b/qpid/python/server010
@@ -5,6 +5,7 @@ from qpid.connection010 import Connection
 from qpid.util import connect, listen
 from qpid.spec010 import load
 from qpid.session import Client
+from qpid.datatypes import Message
 
 spec = load("../specs/amqp.0-10.xml")
 
@@ -27,6 +28,11 @@ class SessionDelegate(Client):
   def queue_query(self, qq):
     return qq.type.result.type.new((qq.queue,), {})
 
+  def message_transfer(self, cmd, header, body):
+    m = Message(body)
+    m.header = header
+    self.session.message_transfer(cmd.destination, cmd.accept_mode, cmd.acquire_mode, m)
+
 server = Server()
 
 for s in listen("0.0.0.0", spec.port):