From ecfaaf9d34f2875abf38598ef0cfbed5d1fd8067 Mon Sep 17 00:00:00 2001 From: Ted Ross Date: Fri, 19 Dec 2008 20:22:03 +0000 Subject: QPID-1412 - c++ implementation of the QMF client API git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@728132 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/examples/qmf-console/console.cpp | 154 ++++++++++++++++++++++++++++++ 1 file changed, 154 insertions(+) create mode 100644 qpid/cpp/examples/qmf-console/console.cpp (limited to 'qpid/cpp/examples/qmf-console/console.cpp') diff --git a/qpid/cpp/examples/qmf-console/console.cpp b/qpid/cpp/examples/qmf-console/console.cpp new file mode 100644 index 0000000000..c98f1ace34 --- /dev/null +++ b/qpid/cpp/examples/qmf-console/console.cpp @@ -0,0 +1,154 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + * + */ + +#include "qpid/console/ConsoleListener.h" +#include "qpid/console/SessionManager.h" +#include "qpid/console/Value.h" +#include +#include +#include + +#include + +using namespace std; +using namespace qpid::console; +using std::cout; +using std::endl; + +class Listener : public ConsoleListener { +public: + ~Listener() {} + + void brokerConnected(const Broker& broker) { + cout << "brokerConnected: " << broker << endl; + } + + void brokerDisconnected(const Broker& broker) { + cout << "brokerDisconnected: " << broker << endl; + } + + void newPackage(const std::string& name) { + cout << "newPackage: " << name << endl; + } + + void newClass(const ClassKey& classKey) { + cout << "newClass: key=" << classKey << endl; + } + + void newAgent(const Agent& agent) { + cout << "newAgent: " << agent << endl; + } + + void delAgent(const Agent& agent) { + cout << "delAgent: " << agent << endl; + } + + void objectProps(Broker& broker, Object& object) { + cout << "objectProps: broker=" << broker << " object=" << object << endl; + } + + void objectStats(Broker& broker, Object& object) { + cout << "objectStats: broker=" << broker << " object=" << object << endl; + } +}; + + +//============================================================== +// Main program +//============================================================== +int main_int(int /*argc*/, char** /*argv*/) +{ + //Listener listener; + qpid::client::ConnectionSettings settings; + + cout << "Creating SessionManager" << endl; + SessionManager sm; + cout << "Adding broker" << endl; + Broker* broker; + + broker = sm.addBroker(settings); + + cout << "Package List:" << endl; + vector packages; + sm.getPackages(packages); + for (vector::iterator iter = packages.begin(); iter != packages.end(); iter++) { + cout << " " << *iter << endl; + SessionManager::KeyVector classKeys; + sm.getClasses(classKeys, *iter); + for (SessionManager::KeyVector::iterator cIter = classKeys.begin(); + cIter != classKeys.end(); cIter++) + cout << " " << *cIter << endl; + } + + Object::Vector list; + cout << "getting exchanges..." << endl; + sm.getObjects(list, "exchange"); + cout << " returned " << list.size() << " elements" << endl; + + for (Object::Vector::iterator i = list.begin(); i != list.end(); i++) { + cout << "exchange: " << *i << endl; + } + + list.clear(); + cout << "getting queues..." << endl; + sm.getObjects(list, "queue"); + cout << " returned " << list.size() << " elements" << endl; + + for (Object::Vector::iterator i = list.begin(); i != list.end(); i++) { + cout << "queue: " << *i << endl; + cout << " bindingCount=" << i->attrUint("bindingCount") << endl; + cout << " arguments=" << i->attrMap("arguments") << endl; + } + + list.clear(); + sm.getObjects(list, "broker"); + if (list.size() == 1) { + Object& broker = *list.begin(); + + cout << "Broker: " << broker << endl; + + Object::AttributeMap args; + MethodResponse result; + args["sequence"] = new UintValue(1); + args["body"] = new StringValue("Testing..."); + + cout << "Call echo method..." << endl; + broker.invokeMethod("echo", args, result); + cout << "Result: code=" << result.code << " text=" << result.text << endl; + for (Object::AttributeMap::iterator aIter = result.arguments.begin(); + aIter != result.arguments.end(); aIter++) { + cout << " Output Arg: " << aIter->first << " => " << aIter->second->str() << endl; + } + } + + sm.delBroker(broker); + return 0; +} + +int main(int argc, char** argv) +{ + try { + return main_int(argc, argv); + } catch(std::exception& e) { + cout << "Top Level Exception: " << e.what() << endl; + } +} + -- cgit v1.2.1 From 564775ae717db7743d41f7620cde8845dc7d35b8 Mon Sep 17 00:00:00 2001 From: Ted Ross Date: Tue, 23 Dec 2008 19:38:25 +0000 Subject: QPID-1412 Updates and fixes for the c++ console API: - Added event support - Converted raw pointers to shared_ptrs in references to Values. This fixes a memory leak in the original code. - Added wrappers to make value access more convenient. - Added timeout handling for synchronous operations. Timeout values are configurable. - Fixed a bug in getObjects whereby waitForStable was not called and the operation could fail if called too early. - Added examples "printevents" and "ping" to illustrate the usage of different aspects of the API. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@729075 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/examples/qmf-console/console.cpp | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) (limited to 'qpid/cpp/examples/qmf-console/console.cpp') diff --git a/qpid/cpp/examples/qmf-console/console.cpp b/qpid/cpp/examples/qmf-console/console.cpp index c98f1ace34..5700d5556f 100644 --- a/qpid/cpp/examples/qmf-console/console.cpp +++ b/qpid/cpp/examples/qmf-console/console.cpp @@ -21,17 +21,9 @@ #include "qpid/console/ConsoleListener.h" #include "qpid/console/SessionManager.h" -#include "qpid/console/Value.h" -#include -#include -#include - -#include using namespace std; using namespace qpid::console; -using std::cout; -using std::endl; class Listener : public ConsoleListener { public: @@ -68,6 +60,10 @@ public: void objectStats(Broker& broker, Object& object) { cout << "objectStats: broker=" << broker << " object=" << object << endl; } + + void event(Event& event) { + cout << "event: " << event << endl; + } }; @@ -127,8 +123,8 @@ int main_int(int /*argc*/, char** /*argv*/) Object::AttributeMap args; MethodResponse result; - args["sequence"] = new UintValue(1); - args["body"] = new StringValue("Testing..."); + args.addUint("sequence", 1); + args.addString("body", "Testing..."); cout << "Call echo method..." << endl; broker.invokeMethod("echo", args, result); -- cgit v1.2.1 From 095fb80c67258ab00a2654bdd4a094f4d37ed4b8 Mon Sep 17 00:00:00 2001 From: Ted Ross Date: Thu, 3 Jun 2010 20:23:30 +0000 Subject: QPID-2644 - Console examples sometimes fail due to not waiting for the broker connection to complete Moved 'Broker::waitForStable' from private to public, used this function in the examples to hold off until the broker is fully connected. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@951141 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/examples/qmf-console/console.cpp | 1 + 1 file changed, 1 insertion(+) (limited to 'qpid/cpp/examples/qmf-console/console.cpp') diff --git a/qpid/cpp/examples/qmf-console/console.cpp b/qpid/cpp/examples/qmf-console/console.cpp index 5700d5556f..b5375b673f 100644 --- a/qpid/cpp/examples/qmf-console/console.cpp +++ b/qpid/cpp/examples/qmf-console/console.cpp @@ -81,6 +81,7 @@ int main_int(int /*argc*/, char** /*argv*/) Broker* broker; broker = sm.addBroker(settings); + broker->waitForStable(); cout << "Package List:" << endl; vector packages; -- cgit v1.2.1