You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2009/03/17 17:38:43 UTC

svn commit: r755315 - /qpid/branches/0.5-release/qpid/cpp/src/qpid/broker/Message.cpp

Author: gsim
Date: Tue Mar 17 16:38:42 2009
New Revision: 755315

URL: http://svn.apache.org/viewvc?rev=755315&view=rev
Log:
QPID-1744: As the cluster sends out update messages using the message frames directly (i.e. not the standard route), need to ensure that the flags on those frames are correct.


Modified:
    qpid/branches/0.5-release/qpid/cpp/src/qpid/broker/Message.cpp

Modified: qpid/branches/0.5-release/qpid/cpp/src/qpid/broker/Message.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/0.5-release/qpid/cpp/src/qpid/broker/Message.cpp?rev=755315&r1=755314&r2=755315&view=diff
==============================================================================
--- qpid/branches/0.5-release/qpid/cpp/src/qpid/broker/Message.cpp (original)
+++ qpid/branches/0.5-release/qpid/cpp/src/qpid/broker/Message.cpp Tue Mar 17 16:38:42 2009
@@ -160,6 +160,7 @@
         //body on a frame then add that frame to the frameset
         AMQFrame frame((AMQContentBody()));
         frame.castBody<AMQContentBody>()->decode(buffer, buffer.available());
+        frame.setFirstSegment(false);
         frames.append(frame);
     } else {
         //adjust header flags



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