Exposed asMap for DataAddr objects in Pyton and Ruby wrappers.

Enhanced the examples to show the passing of a DataAddr in an argument.


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

2 files changed, 42 insertions, 0 deletions

diff --git a/cpp/bindings/qmf2/examples/cpp/agent.cpp b/cpp/bindings/qmf2/examples/cpp/agent.cpp
index 3ec42c8d86..51643e203a 100644
--- a/cpp/bindings/qmf2/examples/cpp/agent.cpp
+++ b/cpp/bindings/qmf2/examples/cpp/agent.cpp
@@ -48,6 +48,7 @@ private:
     AgentSession session;
     Schema sch_exception;
     Schema sch_control;
+    Schema sch_child;
     Data control;
     DataAddr controlAddr;
 
@@ -120,11 +121,23 @@ void ExampleAgent::setupSchema()
     failMethod.addArgument(SchemaProperty("details", SCHEMA_DATA_MAP, "{dir:IN}"));
     sch_control.addMethod(failMethod);
 
+    SchemaMethod createMethod("create_child", "{desc:'Create Child Object'}");
+    createMethod.addArgument(SchemaProperty("name", SCHEMA_DATA_STRING, "{dir:IN}"));
+    createMethod.addArgument(SchemaProperty("childAddr", SCHEMA_DATA_MAP, "{dir:OUT}"));
+    sch_control.addMethod(createMethod);
+
+    //
+    // Declare the child class
+    //
+    sch_child = Schema(SCHEMA_TYPE_DATA, package, "child");
+    sch_child.addProperty(SchemaProperty("name", SCHEMA_DATA_STRING));
+
     //
     // Register our schemata with the agent session.
     //
     session.registerSchema(sch_exception);
     session.registerSchema(sch_control);
+    session.registerSchema(sch_child);
 }
 
 void ExampleAgent::populateData()
@@ -185,6 +198,15 @@ bool ExampleAgent::method(AgentEvent& event)
                 session.raiseException(event, ex);
             }
         }
+
+        if (name == "create_child") {
+            const string& name(event.getArguments()["name"]);
+            Data child(sch_child);
+            child.setProperty("name", name);
+            DataAddr addr(session.addData(child, name));
+            event.addReturnArgument("childAddr", addr.asMap());
+            session.methodSuccess(event);
+        }
     }
 
     return true;
diff --git a/cpp/bindings/qmf2/examples/python/agent.py b/cpp/bindings/qmf2/examples/python/agent.py
index 84d2fe4615..66b7dbdc58 100755
--- a/cpp/bindings/qmf2/examples/python/agent.py
+++ b/cpp/bindings/qmf2/examples/python/agent.py
@@ -88,6 +88,14 @@ class ExampleAgent(AgentHandler):
           ex.details = args['details']
           self.session.raiseException(handle, ex)
 
+      elif methodName == "create_child":
+        name = args['name']
+        child = Data(self.sch_child)
+        child.name = name
+        addr = self.session.addData(child, name)
+        handle.addReturnArgument("childAddr", addr.asMap())
+        self.session.methodSuccess(handle)
+
 
   def setupSchema(self):
     """
@@ -126,11 +134,23 @@ class ExampleAgent(AgentHandler):
     failMethod.addArgument(SchemaProperty("details", SCHEMA_DATA_MAP, direction=DIR_IN))
     self.sch_control.addMethod(failMethod)
 
+    createMethod = SchemaMethod("create_child", desc="Create Child Object")
+    createMethod.addArgument(SchemaProperty("name", SCHEMA_DATA_STRING, direction=DIR_IN))
+    createMethod.addArgument(SchemaProperty("childAddr", SCHEMA_DATA_MAP, direction=DIR_OUT))
+    self.sch_control.addMethod(createMethod)
+
+    ##
+    ## Declare a child object
+    ##
+    self.sch_child = Schema(SCHEMA_TYPE_DATA, package, "child")
+    self.sch_child.addProperty(SchemaProperty("name", SCHEMA_DATA_STRING))
+
     ##
     ## Register our schemata with the agent session.
     ##
     self.session.registerSchema(self.sch_exception)
     self.session.registerSchema(self.sch_control)
+    self.session.registerSchema(self.sch_child)
 
 
   def populateData(self):