Updated Python and Ruby wrappers to reflect API changes.

Updates to the agent examples.


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

2 files changed, 4 insertions, 5 deletions

diff --git a/cpp/bindings/qmf2/examples/cpp/agent.cpp b/cpp/bindings/qmf2/examples/cpp/agent.cpp
index e680ffeeeb..3ec42c8d86 100644
--- a/cpp/bindings/qmf2/examples/cpp/agent.cpp
+++ b/cpp/bindings/qmf2/examples/cpp/agent.cpp
@@ -60,7 +60,7 @@ ExampleAgent::ExampleAgent(const string& url)
     //
     // Create and open a messaging connection to a broker.
     //
-    connection = qpid::messaging::Connection(url);
+    connection = qpid::messaging::Connection(url, "{reconnect:True}");
     connection.open();
 
     //
@@ -132,7 +132,7 @@ void ExampleAgent::populateData()
     //
     // Create a control object and give it to the agent session to manage.
     //
-    control = Data(sch_control.getSchemaId());
+    control = Data(sch_control);
     control.setProperty("state", "OPERATIONAL");
     control.setProperty("methodCount", 0);
     controlAddr = session.addData(control, "singleton");
@@ -178,7 +178,7 @@ bool ExampleAgent::method(AgentEvent& event)
             if (event.getArguments()["useString"])
                 session.raiseException(event, event.getArguments()["stringVal"]);
             else {
-                Data ex(sch_exception.getSchemaId());
+                Data ex(sch_exception);
                 ex.setProperty("whatHappened", "It Failed");
                 ex.setProperty("howBad", 75);
                 ex.setProperty("details", event.getArguments()["details"]);
diff --git a/cpp/bindings/qmf2/examples/python/agent.py b/cpp/bindings/qmf2/examples/python/agent.py
index d354106042..84d2fe4615 100755
--- a/cpp/bindings/qmf2/examples/python/agent.py
+++ b/cpp/bindings/qmf2/examples/python/agent.py
@@ -34,7 +34,7 @@ class ExampleAgent(AgentHandler):
     ##
     ## Create and open a messaging connection to a broker.
     ##
-    self.connection = cqpid.Connection(url)
+    self.connection = cqpid.Connection(url, "{reconnect:True}")
     self.session = None
     self.connection.open()
 
@@ -42,7 +42,6 @@ class ExampleAgent(AgentHandler):
     ## Create, configure, and open a QMFv2 agent session using the connection.
     ##
     self.session = AgentSession(self.connection, "{interval:30}")
-    self.session.setDomain("test")
     self.session.setVendor('profitron.com')
     self.session.setProduct('blastinator')
     self.session.setAttribute('attr1', 1000)