diff options
| author | Alan Conway <aconway@apache.org> | 2008-05-26 18:29:24 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-05-26 18:29:24 +0000 |
| commit | 075ccb73ee9ebcb88652c1960d8a203797dae37a (patch) | |
| tree | 23004e6fd72bab957e2d647d70a017d1f9562df6 /qpid/cpp/examples | |
| parent | 72456749101ecd33ce01f9c79f9e9082985154f6 (diff) | |
| download | qpid-python-075ccb73ee9ebcb88652c1960d8a203797dae37a.tar.gz | |
Corrected examples for new session API.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@660265 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/examples')
6 files changed, 6 insertions, 2 deletions
diff --git a/qpid/cpp/examples/examples/direct/direct_producer.cpp b/qpid/cpp/examples/examples/direct/direct_producer.cpp index 348b82efae..40fc644bf3 100644 --- a/qpid/cpp/examples/examples/direct/direct_producer.cpp +++ b/qpid/cpp/examples/examples/direct/direct_producer.cpp @@ -45,6 +45,7 @@ #include <qpid/client/Connection.h> #include <qpid/client/Session.h> +#include <qpid/client/AsyncSession.h> #include <qpid/client/Message.h> diff --git a/qpid/cpp/examples/examples/fanout/fanout_producer.cpp b/qpid/cpp/examples/examples/fanout/fanout_producer.cpp index 9a80c86c20..a1ca407847 100644 --- a/qpid/cpp/examples/examples/fanout/fanout_producer.cpp +++ b/qpid/cpp/examples/examples/fanout/fanout_producer.cpp @@ -45,6 +45,7 @@ #include <qpid/client/Connection.h> #include <qpid/client/Session.h> +#include <qpid/client/AsyncSession.h> #include <qpid/client/Message.h> diff --git a/qpid/cpp/examples/examples/fanout/listener.cpp b/qpid/cpp/examples/examples/fanout/listener.cpp index 79a115f99f..d9bf9789dc 100644 --- a/qpid/cpp/examples/examples/fanout/listener.cpp +++ b/qpid/cpp/examples/examples/fanout/listener.cpp @@ -79,7 +79,7 @@ int main(int argc, char** argv) { // for routing decisions. It can be useful for tracking // messages and routing in logs. - std::string myQueue=session.getId().str(); + std::string myQueue=session.getId().getName(); session.queueDeclare(arg::queue=myQueue, arg::exclusive=true, arg::autoDelete=true); diff --git a/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp b/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp index edf6ff28f7..ab485fec8f 100644 --- a/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp +++ b/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp @@ -44,6 +44,7 @@ #include <qpid/client/Connection.h> #include <qpid/client/Session.h> +#include <qpid/client/AsyncSession.h> #include <qpid/client/Message.h> diff --git a/qpid/cpp/examples/examples/request-response/client.cpp b/qpid/cpp/examples/examples/request-response/client.cpp index eb4c00c2f1..7540de30ff 100644 --- a/qpid/cpp/examples/examples/request-response/client.cpp +++ b/qpid/cpp/examples/examples/request-response/client.cpp @@ -123,7 +123,7 @@ int main(int argc, char** argv) { // of the response queue. stringstream response_queue; - response_queue << "client" << session.getId(); + response_queue << "client" << session.getId().getName(); // Use the name of the response queue as the routing key diff --git a/qpid/cpp/examples/examples/xml-exchange/xml_producer.cpp b/qpid/cpp/examples/examples/xml-exchange/xml_producer.cpp index 42e9ec4356..19889e4891 100644 --- a/qpid/cpp/examples/examples/xml-exchange/xml_producer.cpp +++ b/qpid/cpp/examples/examples/xml-exchange/xml_producer.cpp @@ -22,6 +22,7 @@ #include <qpid/client/Connection.h> #include <qpid/client/Session.h> +#include <qpid/client/AsyncSession.h> #include <qpid/client/Message.h> |