Update examples with ASYNC mode to newSession

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@629510 13f79535-47bb-0310-9956-ffa450edef68

9 files changed, 9 insertions, 9 deletions

diff --git a/qpid/cpp/examples/examples/direct/declare_queues.cpp b/qpid/cpp/examples/examples/direct/declare_queues.cpp
index d57e6a797b..de7eff0490 100644
--- a/qpid/cpp/examples/examples/direct/declare_queues.cpp
+++ b/qpid/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/qpid/cpp/examples/examples/direct/direct_producer.cpp b/qpid/cpp/examples/examples/direct/direct_producer.cpp
index 515e84c8d9..9b40f733c2 100644
--- a/qpid/cpp/examples/examples/direct/direct_producer.cpp
+++ b/qpid/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/qpid/cpp/examples/examples/direct/listener.cpp b/qpid/cpp/examples/examples/direct/listener.cpp
index 91b5123c68..ae6a7699f1 100644
--- a/qpid/cpp/examples/examples/direct/listener.cpp
+++ b/qpid/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/qpid/cpp/examples/examples/fanout/fanout_producer.cpp b/qpid/cpp/examples/examples/fanout/fanout_producer.cpp
index 7521724920..8ae6bbc242 100644
--- a/qpid/cpp/examples/examples/fanout/fanout_producer.cpp
+++ b/qpid/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/qpid/cpp/examples/examples/fanout/listener.cpp b/qpid/cpp/examples/examples/fanout/listener.cpp
index f465a8554e..2860528b1f 100644
--- a/qpid/cpp/examples/examples/fanout/listener.cpp
+++ b/qpid/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/qpid/cpp/examples/examples/pub-sub/topic_listener.cpp b/qpid/cpp/examples/examples/pub-sub/topic_listener.cpp
index 7fd31f567e..e5292db703 100644
--- a/qpid/cpp/examples/examples/pub-sub/topic_listener.cpp
+++ b/qpid/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/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp b/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp
index ebb2f22215..94cd3a0f56 100644
--- a/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp
+++ b/qpid/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/qpid/cpp/examples/examples/request-response/client.cpp b/qpid/cpp/examples/examples/request-response/client.cpp
index b282e133e7..9f82bd9d9e 100644
--- a/qpid/cpp/examples/examples/request-response/client.cpp
+++ b/qpid/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/qpid/cpp/examples/examples/request-response/server.cpp b/qpid/cpp/examples/examples/request-response/server.cpp
index 4f87d8b253..0de2ce5234 100644
--- a/qpid/cpp/examples/examples/request-response/server.cpp
+++ b/qpid/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 --------------------------------------------