[rhmessaging-commits] rhmessaging commits: r3446 - store/trunk/cpp/tests.

rhmessaging-commits at lists.jboss.org rhmessaging-commits at lists.jboss.org
Thu Jun 11 09:29:47 EDT 2009


Author: gordonsim
Date: 2009-06-11 09:29:47 -0400 (Thu, 11 Jun 2009)
New Revision: 3446

Modified:
   store/trunk/cpp/tests/MessageUtils.h
Log:
Fix frame flags where content will follow header



Modified: store/trunk/cpp/tests/MessageUtils.h
===================================================================
--- store/trunk/cpp/tests/MessageUtils.h	2009-06-11 13:10:56 UTC (rev 3445)
+++ store/trunk/cpp/tests/MessageUtils.h	2009-06-11 13:29:47 UTC (rev 3446)
@@ -32,12 +32,13 @@
 struct MessageUtils
 {
     static boost::intrusive_ptr<Message> createMessage(const string& exchange, const string& routingKey,
-                                             const Uuid& messageId=Uuid(), uint64_t contentSize = 0)
+                                                       const Uuid& messageId=Uuid(), uint64_t contentSize = 0)
     {
         boost::intrusive_ptr<Message> msg(new Message());
 
         AMQFrame method((MessageTransferBody(ProtocolVersion(), exchange, 0, 0)));
         AMQFrame header((AMQHeaderBody()));
+        header.setLastSegment(contentSize == 0);
 
         msg->getFrames().append(method);
         msg->getFrames().append(header);




More information about the rhmessaging-commits mailing list