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 --------------------------------------------
