You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2008/02/20 16:36:27 UTC
svn commit: r629510 - in /incubator/qpid/trunk/qpid/cpp/examples/examples:
direct/ fanout/ pub-sub/ request-response/
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 --------------------------------------------