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 2013/07/30 18:51:11 UTC
svn commit: r1508516 -
/qpid/trunk/qpid/cpp/src/qpid/broker/DeliveryRecord.cpp
Author: gsim
Date: Tue Jul 30 16:51:11 2013
New Revision: 1508516
URL: http://svn.apache.org/r1508516
Log:
QPID-5025: check that delivery has not already been ended before signalling commit of dequeue
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/DeliveryRecord.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/DeliveryRecord.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/DeliveryRecord.cpp?rev=1508516&r1=1508515&r2=1508516&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/DeliveryRecord.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/DeliveryRecord.cpp Tue Jul 30 16:51:11 2013
@@ -106,7 +106,9 @@ void DeliveryRecord::dequeue(Transaction
void DeliveryRecord::committed() const
{
- queue->dequeueCommitted(msg);
+ if (acquired && !ended) {
+ queue->dequeueCommitted(msg);
+ }
}
void DeliveryRecord::reject()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org