diff options
author | Gordon Sim <gsim@apache.org> | 2009-11-11 13:15:44 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2009-11-11 13:15:44 +0000 |
commit | 856e5e92e6ad376cdbe3c8c2b8414415a17e579c (patch) | |
tree | 4b60cb6515225326ac1c60c04ef42765ccd3aa5c /cpp/examples/messaging/topic_receiver.cpp | |
parent | 36c30decd36c54d5d361cfa64818d10527960b85 (diff) | |
download | qpid-python-856e5e92e6ad376cdbe3c8c2b8414415a17e579c.tar.gz |
Added support for address parsing, create/assert/delete policies
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@834869 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/examples/messaging/topic_receiver.cpp')
-rw-r--r-- | cpp/examples/messaging/topic_receiver.cpp | 15 |
1 files changed, 4 insertions, 11 deletions
diff --git a/cpp/examples/messaging/topic_receiver.cpp b/cpp/examples/messaging/topic_receiver.cpp index 7352a91b30..6f6c1a5677 100644 --- a/cpp/examples/messaging/topic_receiver.cpp +++ b/cpp/examples/messaging/topic_receiver.cpp @@ -19,32 +19,25 @@ * */ -#include <qpid/messaging/Address.h> #include <qpid/messaging/Connection.h> -#include <qpid/messaging/Filter.h> #include <qpid/messaging/Message.h> #include <qpid/messaging/Receiver.h> #include <qpid/messaging/Session.h> +#include <qpid/messaging/Variant.h> #include <cstdlib> #include <iostream> -#include <sstream> - using namespace qpid::messaging; -using std::stringstream; -using std::string; - int main(int argc, char** argv) { - const char* url = argc>1 ? argv[1] : "amqp:tcp:127.0.0.1:5672"; - const char* pattern = argc>2 ? argv[2] : "#.#"; + const std::string url = argc>1 ? argv[1] : "amqp:tcp:127.0.0.1:5672"; + const std::string pattern = argc>2 ? argv[2] : "#.#"; try { Connection connection = Connection::open(url); Session session = connection.newSession(); - Filter filter(Filter::WILDCARD, pattern, "control"); - Receiver receiver = session.createReceiver(Address("news_service", "topic"), filter); + Receiver receiver = session.createReceiver("news_service {filter:[control, " + pattern + "]}"); while (true) { Message message = receiver.fetch(); std::cout << "Message: " << message.getContent() << std::endl; |