summaryrefslogtreecommitdiff
path: root/cpp/examples/messaging/topic_receiver.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2009-11-11 13:15:44 +0000
committerGordon Sim <gsim@apache.org>2009-11-11 13:15:44 +0000
commit856e5e92e6ad376cdbe3c8c2b8414415a17e579c (patch)
tree4b60cb6515225326ac1c60c04ef42765ccd3aa5c /cpp/examples/messaging/topic_receiver.cpp
parent36c30decd36c54d5d361cfa64818d10527960b85 (diff)
downloadqpid-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.cpp15
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;