diff options
| author | Andrew Stitcher <astitcher@apache.org> | 2007-02-23 15:41:28 +0000 |
|---|---|---|
| committer | Andrew Stitcher <astitcher@apache.org> | 2007-02-23 15:41:28 +0000 |
| commit | 1cc1d341c699653811bf0e160d398214db787230 (patch) | |
| tree | cdceab43260c481d3cb3fb08d669863e0525a866 /cpp/lib | |
| parent | 1c0a6a459f71821962e3c5718e174c1baeda0019 (diff) | |
| download | qpid-python-1cc1d341c699653811bf0e160d398214db787230.tar.gz | |
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
Diffstat (limited to 'cpp/lib')
| -rw-r--r-- | cpp/lib/broker/BrokerChannel.cpp | 4 |
1 files changed, 1 insertions, 3 deletions
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 |