[email protected] wrote:
Author: kpvdr
Date: Fri May  1 19:17:59 2009
New Revision: 770796

URL: http://svn.apache.org/viewvc?rev=770796&view=rev

Kim,

Revisiting the cluster tests recently I noticed all the messageTransfer() requests had an additional argument (e.g. as below) and tracked this back to your earlier commit.

However messageTransfer() does not take a durable argument so this addition will have no effect. To make the messages persistent you need to set the delivery mode on the delivery properties.

--Gordon.

-    c0.session.queueDeclare(arg::queue="q");
-    c0.session.messageTransfer(arg::content=Message("A", "q"));
-    c0.session.messageTransfer(arg::content=Message("B", "q"));
+    c0.session.queueDeclare(arg::queue="q", arg::durable=durableFlag);
+    c0.session.messageTransfer(arg::content=Message("A", "q"), 
arg::durable=durableFlag);
+    c0.session.messageTransfer(arg::content=Message("B", "q"), 
arg::durable=durableFlag);

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:[email protected]

Reply via email to