diff options
Diffstat (limited to 'cpp/src/qpid/broker/DtxAck.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/DtxAck.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
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(); } |