On Wed, 2009-05-27 at 14:27 +0100, Gordon Sim wrote: > [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); > Thanks for pointing this out. I'll fix it right away. I checked the store files, and they are empty.
Kim --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
