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

4 files changed, 48 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):
diff --git a/cpp/bindings/qmf2/python/qmf2.py b/cpp/bindings/qmf2/python/qmf2.py
index 911b080dfd..37efb8708b 100644
--- a/cpp/bindings/qmf2/python/qmf2.py
+++ b/cpp/bindings/qmf2/python/qmf2.py
@@ -533,6 +533,11 @@ class DataAddr(object):
         self.getName() == other.getName() and \
         self.getAgentEpoch() == other.getAgentEpoch()
 
+  def asMap(self):
+    """
+    """
+    return self._impl.asMap()
+
   def getAgentName(self):
     """
     """
diff --git a/cpp/bindings/qmf2/ruby/qmf2.rb b/cpp/bindings/qmf2/ruby/qmf2.rb
index 65cc695c45..86ba72cc0b 100644
--- a/cpp/bindings/qmf2/ruby/qmf2.rb
+++ b/cpp/bindings/qmf2/ruby/qmf2.rb
@@ -404,6 +404,7 @@ module Qmf2
       return @impl == other.impl
     end
 
+    def as_map()       @impl.asMap          end
     def agent_name()   @impl.getAgentName   end
     def name()         @impl.getName        end
     def agent_epoch()  @impl.getAgentEpoch  end