From 1cc1d341c699653811bf0e160d398214db787230 Mon Sep 17 00:00:00 2001 From: Andrew Stitcher Date: Fri, 23 Feb 2007 15:41:28 +0000 Subject: r1237@fuschia: andrew | 2007-02-23 15:40:44 +0000 Bug in acks - Small typo fixed git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@510986 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/lib/broker/BrokerChannel.cpp | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) (limited to 'cpp/lib') diff --git a/cpp/lib/broker/BrokerChannel.cpp b/cpp/lib/broker/BrokerChannel.cpp index fc82e3111d..ddf9ad0e3c 100644 --- a/cpp/lib/broker/BrokerChannel.cpp +++ b/cpp/lib/broker/BrokerChannel.cpp @@ -233,7 +233,6 @@ void Channel::complete(Message::shared_ptr msg) { } } -// TODO astitcher 2007-02-08 This only deals correctly with non batched responses void Channel::ack(){ ack(getFirstAckRequest(), getLastAckRequest()); } @@ -248,8 +247,7 @@ void Channel::ack(u_int64_t deliveryTag, bool multiple){ void Channel::ack(u_int64_t firstTag, u_int64_t lastTag){ if(transactional){ - //FIXME astitcher This only works for Basic style acks - accumulatedAck.update(lastTag, lastTag); + accumulatedAck.update(firstTag, lastTag); //TODO: I think the outstanding prefetch size & count should be updated at this point... //TODO: ...this may then necessitate dispatching to consumers -- cgit v1.2.1