From 1d43a6daa6d168bc5728cb9e70e9539cac295787 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 20 Feb 2008 15:36:18 +0000 Subject: Update examples with ASYNC mode to newSession git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629510 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/examples/examples/direct/declare_queues.cpp | 2 +- cpp/examples/examples/direct/direct_producer.cpp | 2 +- cpp/examples/examples/direct/listener.cpp | 2 +- cpp/examples/examples/fanout/fanout_producer.cpp | 2 +- cpp/examples/examples/fanout/listener.cpp | 2 +- cpp/examples/examples/pub-sub/topic_listener.cpp | 2 +- cpp/examples/examples/pub-sub/topic_publisher.cpp | 2 +- cpp/examples/examples/request-response/client.cpp | 2 +- cpp/examples/examples/request-response/server.cpp | 2 +- 9 files changed, 9 insertions(+), 9 deletions(-) (limited to 'cpp/examples') diff --git a/cpp/examples/examples/direct/declare_queues.cpp b/cpp/examples/examples/direct/declare_queues.cpp index d57e6a797b..de7eff0490 100644 --- a/cpp/examples/examples/direct/declare_queues.cpp +++ b/cpp/examples/examples/direct/declare_queues.cpp @@ -60,7 +60,7 @@ int main(int argc, char** argv) { Message msg; try { connection.open(host, port); - Session session = connection.newSession(); + Session session = connection.newSession(ASYNC); //--------- Main body of program -------------------------------------------- diff --git a/cpp/examples/examples/direct/direct_producer.cpp b/cpp/examples/examples/direct/direct_producer.cpp index 515e84c8d9..9b40f733c2 100644 --- a/cpp/examples/examples/direct/direct_producer.cpp +++ b/cpp/examples/examples/direct/direct_producer.cpp @@ -67,7 +67,7 @@ int main(int argc, char** argv) { Message message; try { connection.open(host, port); - Session session = connection.newSession(); + Session session = connection.newSession(ASYNC); //--------- Main body of program -------------------------------------------- diff --git a/cpp/examples/examples/direct/listener.cpp b/cpp/examples/examples/direct/listener.cpp index 91b5123c68..ae6a7699f1 100644 --- a/cpp/examples/examples/direct/listener.cpp +++ b/cpp/examples/examples/direct/listener.cpp @@ -65,7 +65,7 @@ int main(int argc, char** argv) { Message msg; try { connection.open(host, port); - Session session = connection.newSession(); + Session session = connection.newSession(ASYNC); //--------- Main body of program -------------------------------------------- diff --git a/cpp/examples/examples/fanout/fanout_producer.cpp b/cpp/examples/examples/fanout/fanout_producer.cpp index 7521724920..8ae6bbc242 100644 --- a/cpp/examples/examples/fanout/fanout_producer.cpp +++ b/cpp/examples/examples/fanout/fanout_producer.cpp @@ -67,7 +67,7 @@ int main(int argc, char** argv) { Message message; try { connection.open(host, port); - Session session = connection.newSession(); + Session session = connection.newSession(ASYNC); //--------- Main body of program -------------------------------------------- diff --git a/cpp/examples/examples/fanout/listener.cpp b/cpp/examples/examples/fanout/listener.cpp index f465a8554e..2860528b1f 100644 --- a/cpp/examples/examples/fanout/listener.cpp +++ b/cpp/examples/examples/fanout/listener.cpp @@ -65,7 +65,7 @@ int main(int argc, char** argv) { Message msg; try { connection.open(host, port); - Session session = connection.newSession(); + Session session = connection.newSession(ASYNC); //--------- Main body of program -------------------------------------------- diff --git a/cpp/examples/examples/pub-sub/topic_listener.cpp b/cpp/examples/examples/pub-sub/topic_listener.cpp index 7fd31f567e..e5292db703 100644 --- a/cpp/examples/examples/pub-sub/topic_listener.cpp +++ b/cpp/examples/examples/pub-sub/topic_listener.cpp @@ -138,7 +138,7 @@ int main(int argc, char** argv) { Connection connection; try { connection.open(host, port); - Session session = connection.newSession(); + Session session = connection.newSession(ASYNC); //--------- Main body of program -------------------------------------------- diff --git a/cpp/examples/examples/pub-sub/topic_publisher.cpp b/cpp/examples/examples/pub-sub/topic_publisher.cpp index ebb2f22215..94cd3a0f56 100644 --- a/cpp/examples/examples/pub-sub/topic_publisher.cpp +++ b/cpp/examples/examples/pub-sub/topic_publisher.cpp @@ -101,7 +101,7 @@ int main(int argc, char** argv) { Message message; try { connection.open(host, port); - Session session = connection.newSession(); + Session session = connection.newSession(ASYNC); //--------- Main body of program -------------------------------------------- diff --git a/cpp/examples/examples/request-response/client.cpp b/cpp/examples/examples/request-response/client.cpp index b282e133e7..9f82bd9d9e 100644 --- a/cpp/examples/examples/request-response/client.cpp +++ b/cpp/examples/examples/request-response/client.cpp @@ -114,7 +114,7 @@ int main(int argc, char** argv) { Message request; try { connection.open(host, port); - Session session = connection.newSession(); + Session session = connection.newSession(ASYNC); //--------- Main body of program -------------------------------------------- diff --git a/cpp/examples/examples/request-response/server.cpp b/cpp/examples/examples/request-response/server.cpp index 4f87d8b253..0de2ce5234 100644 --- a/cpp/examples/examples/request-response/server.cpp +++ b/cpp/examples/examples/request-response/server.cpp @@ -131,7 +131,7 @@ int main(int argc, char** argv) { Message message; try { connection.open(host, port); - Session session = connection.newSession(); + Session session = connection.newSession(ASYNC); //--------- Main body of program -------------------------------------------- -- cgit v1.2.1