summaryrefslogtreecommitdiff
path: root/cpp/bindings/qmf2/examples/python
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2011-01-11 17:58:04 +0000
committerTed Ross <tross@apache.org>2011-01-11 17:58:04 +0000
commit68f0a6faee3ba7d359ea0e48229cda1faba1f421 (patch)
tree07a3cd6efff4123c6e0b62e9cf99cb92967a14b0 /cpp/bindings/qmf2/examples/python
parenta3fa590892df1c668409a3ef468b74838e873832 (diff)
downloadqpid-python-68f0a6faee3ba7d359ea0e48229cda1faba1f421.tar.gz
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
Diffstat (limited to 'cpp/bindings/qmf2/examples/python')
-rwxr-xr-xcpp/bindings/qmf2/examples/python/agent.py20
1 files changed, 20 insertions, 0 deletions
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):