qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject svn commit: r890239 - in /qpid/trunk/qpid/cpp/examples/messaging: client.cpp server.cpp
Date Mon, 14 Dec 2009 09:04:39 GMT
Author: gsim
Date: Mon Dec 14 09:04:38 2009
New Revision: 890239

URL: http://svn.apache.org/viewvc?rev=890239&view=rev
Log:
Corrected setting of auto-delete in client-server example; configured server address to create
queue if needed.

Modified:
    qpid/trunk/qpid/cpp/examples/messaging/client.cpp
    qpid/trunk/qpid/cpp/examples/messaging/server.cpp

Modified: qpid/trunk/qpid/cpp/examples/messaging/client.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/examples/messaging/client.cpp?rev=890239&r1=890238&r2=890239&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/examples/messaging/client.cpp (original)
+++ qpid/trunk/qpid/cpp/examples/messaging/client.cpp Mon Dec 14 09:04:38 2009
@@ -46,7 +46,7 @@
         Sender sender = session.createSender("service_queue");
 
         //create temp queue & receiver...
-        Address responseQueue("#response-queue; {create:always, type:queue, node-properties:{x-amqp0-10-auto-delete:true}}");
+        Address responseQueue("#response-queue; {create:always, type:queue, node-properties:{
x-properties:{auto-delete:true}}}");
         Receiver receiver = session.createReceiver(responseQueue);
 
 	// Now send some messages ...

Modified: qpid/trunk/qpid/cpp/examples/messaging/server.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/examples/messaging/server.cpp?rev=890239&r1=890238&r2=890239&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/examples/messaging/server.cpp (original)
+++ qpid/trunk/qpid/cpp/examples/messaging/server.cpp Mon Dec 14 09:04:38 2009
@@ -44,7 +44,7 @@
     try {
         Connection connection = Connection::open(url);
         Session session = connection.newSession();
-        Receiver receiver = session.createReceiver("service_queue");
+        Receiver receiver = session.createReceiver("service_queue; {create: always}");
 
         while (true) {
             Message request = receiver.fetch();



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message