qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject svn commit: r629510 - in /incubator/qpid/trunk/qpid/cpp/examples/examples: direct/ fanout/ pub-sub/ request-response/
Date Wed, 20 Feb 2008 15:36:27 GMT
Author: aconway
Date: Wed Feb 20 07:36:18 2008
New Revision: 629510

URL: http://svn.apache.org/viewvc?rev=629510&view=rev
Log:
Update examples with ASYNC mode to newSession

Modified:
    incubator/qpid/trunk/qpid/cpp/examples/examples/direct/declare_queues.cpp
    incubator/qpid/trunk/qpid/cpp/examples/examples/direct/direct_producer.cpp
    incubator/qpid/trunk/qpid/cpp/examples/examples/direct/listener.cpp
    incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/fanout_producer.cpp
    incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/listener.cpp
    incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_listener.cpp
    incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp
    incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp
    incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp

Modified: incubator/qpid/trunk/qpid/cpp/examples/examples/direct/declare_queues.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/direct/declare_queues.cpp?rev=629510&r1=629509&r2=629510&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/direct/declare_queues.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/direct/declare_queues.cpp Wed Feb 20 07:36:18
2008
@@ -60,7 +60,7 @@
     Message msg;
     try {
       connection.open(host, port);
-      Session session =  connection.newSession();
+      Session session =  connection.newSession(ASYNC);
 
 
   //--------- Main body of program --------------------------------------------

Modified: incubator/qpid/trunk/qpid/cpp/examples/examples/direct/direct_producer.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/direct/direct_producer.cpp?rev=629510&r1=629509&r2=629510&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/direct/direct_producer.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/direct/direct_producer.cpp Wed Feb 20
07:36:18 2008
@@ -67,7 +67,7 @@
     Message message;
     try {
         connection.open(host, port);
-        Session session =  connection.newSession();
+        Session session =  connection.newSession(ASYNC);
 
   //--------- Main body of program --------------------------------------------
 

Modified: incubator/qpid/trunk/qpid/cpp/examples/examples/direct/listener.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/direct/listener.cpp?rev=629510&r1=629509&r2=629510&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/direct/listener.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/direct/listener.cpp Wed Feb 20 07:36:18
2008
@@ -65,7 +65,7 @@
     Message msg;
     try {
       connection.open(host, port);
-      Session session =  connection.newSession();
+      Session session =  connection.newSession(ASYNC);
 
   //--------- Main body of program --------------------------------------------
 

Modified: incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/fanout_producer.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/fanout_producer.cpp?rev=629510&r1=629509&r2=629510&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/fanout_producer.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/fanout_producer.cpp Wed Feb 20
07:36:18 2008
@@ -67,7 +67,7 @@
     Message message;
     try {
         connection.open(host, port);
-        Session session =  connection.newSession();
+        Session session =  connection.newSession(ASYNC);
 
   //--------- Main body of program --------------------------------------------
 

Modified: incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/listener.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/listener.cpp?rev=629510&r1=629509&r2=629510&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/listener.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/fanout/listener.cpp Wed Feb 20 07:36:18
2008
@@ -65,7 +65,7 @@
     Message msg;
     try {
         connection.open(host, port);
-        Session session =  connection.newSession();
+        Session session =  connection.newSession(ASYNC);
 
         //--------- Main body of program --------------------------------------------
 

Modified: incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_listener.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_listener.cpp?rev=629510&r1=629509&r2=629510&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_listener.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_listener.cpp Wed Feb 20
07:36:18 2008
@@ -138,7 +138,7 @@
     Connection connection;
     try {
         connection.open(host, port);
-        Session session =  connection.newSession();
+        Session session =  connection.newSession(ASYNC);
 
         //--------- Main body of program --------------------------------------------
 

Modified: incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp?rev=629510&r1=629509&r2=629510&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/pub-sub/topic_publisher.cpp Wed Feb 20
07:36:18 2008
@@ -101,7 +101,7 @@
     Message message;
     try {
         connection.open(host, port);
-        Session session =  connection.newSession();
+        Session session =  connection.newSession(ASYNC);
 
   //--------- Main body of program --------------------------------------------
 

Modified: incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp?rev=629510&r1=629509&r2=629510&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/client.cpp Wed Feb 20
07:36:18 2008
@@ -114,7 +114,7 @@
     Message request;
     try {
         connection.open(host, port);
-        Session session =  connection.newSession();
+        Session session =  connection.newSession(ASYNC);
 
   //--------- Main body of program --------------------------------------------
 

Modified: incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp?rev=629510&r1=629509&r2=629510&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/examples/examples/request-response/server.cpp Wed Feb 20
07:36:18 2008
@@ -131,7 +131,7 @@
     Message message;
     try {
         connection.open(host, port);
-        Session session =  connection.newSession();
+        Session session =  connection.newSession(ASYNC);
 
   //--------- Main body of program --------------------------------------------
 



Mime
View raw message