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 2006/12/01 16:14:02 UTC
svn commit: r481261 -
/incubator/qpid/trunk/qpid/cpp/lib/broker/BrokerQueue.cpp
Author: gsim
Date: Fri Dec 1 07:14:01 2006
New Revision: 481261
URL: http://svn.apache.org/viewvc?view=rev&rev=481261
Log:
Modification to ensure lazy loading is setup correctly where required on recovery.
Modified:
incubator/qpid/trunk/qpid/cpp/lib/broker/BrokerQueue.cpp
Modified: incubator/qpid/trunk/qpid/cpp/lib/broker/BrokerQueue.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/lib/broker/BrokerQueue.cpp?view=diff&rev=481261&r1=481260&r2=481261
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/lib/broker/BrokerQueue.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/lib/broker/BrokerQueue.cpp Fri Dec 1 07:14:01 2006
@@ -64,6 +64,9 @@
void Queue::recover(Message::shared_ptr& msg){
queueing = true;
messages.push(msg);
+ if (store && msg->expectedContentSize() != msg->encodedContentSize()) {
+ msg->releaseContent(store);
+ }
}
void Queue::process(Message::shared_ptr& msg){