diff options
author | Alan Conway <aconway@apache.org> | 2007-11-09 02:38:33 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2007-11-09 02:38:33 +0000 |
commit | ae0962a592ffb21660dcb41f92bf2d80428f72c1 (patch) | |
tree | a794e7b043e01e3e8652e82b85a9586356320263 /qpid/cpp/examples/direct/direct_config_queues.cpp | |
parent | 59c875183c8c4aad0bd7424b2742770a7c675db5 (diff) | |
download | qpid-python-ae0962a592ffb21660dcb41f92bf2d80428f72c1.tar.gz |
QPID-676: Jonathan Robie's C++ examples.
Made the following alterations for recent C++ API changes:
- use arg:: namespace for Session keyword arguments.
- removed trailing _ on session method names.
cpp/examples/Makefile.am calls make in each example directory with
flags to build examples from headers/libraries SVN checkout.
Examples themselves have a plain Makefile (not automake) which will
work as is if qpid is installed in standard places.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@593402 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/examples/direct/direct_config_queues.cpp')
-rw-r--r-- | qpid/cpp/examples/direct/direct_config_queues.cpp | 86 |
1 files changed, 86 insertions, 0 deletions
diff --git a/qpid/cpp/examples/direct/direct_config_queues.cpp b/qpid/cpp/examples/direct/direct_config_queues.cpp new file mode 100644 index 0000000000..3a52d4f62f --- /dev/null +++ b/qpid/cpp/examples/direct/direct_config_queues.cpp @@ -0,0 +1,86 @@ +/* + * + * 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. + * + */ + +/** + * direct_config_queues.cpp + * + * This program is one of three programs designed to be used + * together. These programs do not specify the exchange type - the + * default exchange type is the direct exchange. + * + * direct_config_queues.cpp (this program): + * + * Creates a queue on a broker, binding a routing key to route + * messages to that queue. + * + * direct_publisher.cpp: + * + * Publishes to a broker, specifying a routing key. + * + * direct_listener.cpp + * + * Reads from a queue on the broker using a message listener. + * + */ + +#include <qpid/client/Connection.h> +#include <qpid/client/Session.h> + +#include <unistd.h> +#include <cstdlib> +#include <iostream> + +using namespace qpid::client; +using namespace qpid::framing; + +using std::string; + + +int main() { + Connection connection; + Message msg; + try { + connection.open("127.0.0.1", 5672); + Session session = connection.newSession(); + + + //--------- Main body of program -------------------------------------------- + + // Create a queue named "message_queue", and route all messages whose + // routing key is "routing_key to this newly created queue. + + session.queueDeclare(arg::queue="message_queue"); + session.queueBind(arg::queue="message_queue", arg::routingKey="routing_key"); + + + //----------------------------------------------------------------------------- + + connection.close(); + return 0; + } catch(const std::exception& error) { + std::cout << error.what() << std::endl; + } + return 1; + +} + + + |