From f6f56f56ebb092d8808119a66ced9fcd0399b238 Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Mon, 10 Nov 2008 17:05:41 +0000 Subject: QPID-1445 patch from Jonathan git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@712699 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/examples/xml-exchange/declare_queues.cpp | 25 ++++++++++++++++++++++++- 1 file changed, 24 insertions(+), 1 deletion(-) (limited to 'cpp/examples/xml-exchange/declare_queues.cpp') diff --git a/cpp/examples/xml-exchange/declare_queues.cpp b/cpp/examples/xml-exchange/declare_queues.cpp index 1307c473c5..d3a0f539b6 100644 --- a/cpp/examples/xml-exchange/declare_queues.cpp +++ b/cpp/examples/xml-exchange/declare_queues.cpp @@ -19,6 +19,29 @@ * */ + +/** + * + * declare_queues.cpp + * + * This is one of three programs used to implement XML-based content + * routing in C++. + * + * declare_queues.cpp (this program) + * + * Creates a queue named "message_qaueue" on the broker, + * declares an XML Exchange, subscribes the queue to the XML + * Exchange using an XQuery in the binding, then exits. + * + * xml_producer.cpp + * + * Publishes messages to the XML Exchange. + * + * listener.cpp + * + * Reads messages from the "message_queue" queue. + */ + #include #include @@ -59,7 +82,7 @@ int main(int argc, char** argv) { FieldTable binding; binding.setString("xquery", "declare variable $control external;" "./message/id mod 2 = 1 or $control = 'end'"); - session.exchangeBind(arg::exchange="xml", arg::queue="message_queue", arg::bindingKey="query_name", arg::arguments=binding); + session.exchangeBind(arg::exchange="xml", arg::queue="message_queue", arg::bindingKey="content_feed", arg::arguments=binding); //----------------------------------------------------------------------------- -- cgit v1.2.1