diff options
author | Rajith Muditha Attapattu <rajith@apache.org> | 2011-05-27 15:44:23 +0000 |
---|---|---|
committer | Rajith Muditha Attapattu <rajith@apache.org> | 2011-05-27 15:44:23 +0000 |
commit | 66765100f4257159622cefe57bed50125a5ad017 (patch) | |
tree | a88ee23bb194eb91f0ebb2d9b23ff423e3ea8e37 /cpp/examples/qmf-console/console.cpp | |
parent | 1aeaa7b16e5ce54f10c901d75c4d40f9f88b9db6 (diff) | |
parent | 88b98b2f4152ef59a671fad55a0d08338b6b78ca (diff) | |
download | qpid-python-rajith_jms_client.tar.gz |
Creating a branch for experimenting with some ideas for JMS client.rajith_jms_client
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/rajith_jms_client@1128369 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/examples/qmf-console/console.cpp')
-rw-r--r-- | cpp/examples/qmf-console/console.cpp | 151 |
1 files changed, 0 insertions, 151 deletions
diff --git a/cpp/examples/qmf-console/console.cpp b/cpp/examples/qmf-console/console.cpp deleted file mode 100644 index b5375b673f..0000000000 --- a/cpp/examples/qmf-console/console.cpp +++ /dev/null @@ -1,151 +0,0 @@ -/* - * - * 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" - -using namespace std; -using namespace qpid::console; - -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; - } - - void event(Event& event) { - cout << "event: " << event << 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); - broker->waitForStable(); - - cout << "Package List:" << endl; - vector<string> packages; - sm.getPackages(packages); - for (vector<string>::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.addUint("sequence", 1); - args.addString("body", "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; - } -} - |