From a03d20dd52beb9588bcff3fa0924489372172f18 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 1 Dec 2008 19:49:23 +0000 Subject: QPID-1497: Ensure policy count and size reflect transactionality of dequeues git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@722200 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/DtxAck.cpp | 1 + 1 file changed, 1 insertion(+) (limited to 'cpp/src/qpid/broker/DtxAck.cpp') diff --git a/cpp/src/qpid/broker/DtxAck.cpp b/cpp/src/qpid/broker/DtxAck.cpp index 100ce2492d..bc7d662afb 100644 --- a/cpp/src/qpid/broker/DtxAck.cpp +++ b/cpp/src/qpid/broker/DtxAck.cpp @@ -48,6 +48,7 @@ bool DtxAck::prepare(TransactionContext* ctxt) throw() void DtxAck::commit() throw() { + for_each(pending.begin(), pending.end(), mem_fun_ref(&DeliveryRecord::committed)); pending.clear(); } -- cgit v1.2.1