diff options
Diffstat (limited to 'cpp/src/qpid/broker/TxAck.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/TxAck.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/TxAck.cpp b/cpp/src/qpid/broker/TxAck.cpp index b02e669f02..958dbcbec0 100644 --- a/cpp/src/qpid/broker/TxAck.cpp +++ b/cpp/src/qpid/broker/TxAck.cpp @@ -36,7 +36,7 @@ bool TxAck::prepare(TransactionContext* ctxt) throw(){ //dequeue all acked messages from their queues for (ack_iterator i = unacked.begin(); i != unacked.end(); i++) { if (i->coveredBy(&acked)) { - i->discard(ctxt); + i->dequeue(ctxt); } } return true; |