You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by pm...@apache.org on 2013/09/10 11:20:04 UTC
svn commit: r1521391 - /qpid/trunk/qpid/cpp/src/qpid/broker/Lvq.cpp
Author: pmoravec
Date: Tue Sep 10 09:20:04 2013
New Revision: 1521391
URL: http://svn.apache.org/r1521391
Log:
QPID-5124: durable LVQ raises journal error when only transient messages are sent
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/Lvq.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Lvq.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Lvq.cpp?rev=1521391&r1=1521390&r2=1521391&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Lvq.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Lvq.cpp Tue Sep 10 09:20:04 2013
@@ -57,7 +57,8 @@ void Lvq::push(Message& message, bool is
copy.notify();
if (removed) {
if (isRecovery) pendingDequeues.push_back(old);
- else dequeueFromStore(old.getPersistentContext());//do outside of lock
+ else if (old.isPersistent())
+ dequeueFromStore(old.getPersistentContext());//do outside of lock
}
}
}} // namespace qpid::broker
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org