Author: gsim
Date: Tue Mar 26 18:09:27 2013
New Revision: 1461248
URL: http://svn.apache.org/r1461248
Log:
QPID-4667: Fix for selective message acknowledgement over AMQP 1.0
Modified:
qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/SessionContext.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/SessionContext.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/SessionContext.cpp?rev=1461248&r1=1461247&r2=1461248&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/SessionContext.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/messaging/amqp/SessionContext.cpp Tue Mar 26
18:09:27 2013
@@ -138,9 +138,13 @@ void SessionContext::acknowledge()
void SessionContext::acknowledge(const qpid::framing::SequenceNumber& id, bool
cumulative)
{
+ QPID_LOG(debug, "acknowledging selected messages, id=" << id << ",
cumulative=" << cumulative);
DeliveryMap::iterator i = unacked.find(id);
if (i != unacked.end()) {
- acknowledge(cumulative ? unacked.begin() : i, ++i);
+ DeliveryMap::iterator start = cumulative ? unacked.begin() : i;
+ acknowledge(start, ++i);
+ } else {
+ QPID_LOG(debug, "selective acknowledgement failed; message not found
for id " << id);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
