| Apache Qpid - AMQP Messaging for Java JMS, C++, Python, Ruby, and .NET | Apache Qpid Documentation |
#include <AccumulatedAck.h>
Public Member Functions | |
| AccumulatedAck (SequenceNumber r=SequenceNumber()) | |
| void | update (SequenceNumber firstTag, SequenceNumber lastTag) |
| void | consolidate () |
| void | clear () |
| bool | covers (SequenceNumber tag) const |
| void | collectRanges (SequenceNumberSet &set) const |
| void | update (const SequenceNumber cumulative, const SequenceNumberSet &range) |
| void | operator() (SequenceNumber first, SequenceNumber last) |
Public Attributes | |
| SequenceNumber | mark |
| Everything up to this value has been acknowledged. | |
| std::list< Range > | ranges |
| List of individually acknowledged messages greater than the 'mark'. | |
Definition at line 49 of file AccumulatedAck.h.
| qpid::framing::AccumulatedAck::AccumulatedAck | ( | SequenceNumber | r = SequenceNumber() |
) | [explicit] |
| void qpid::framing::AccumulatedAck::clear | ( | ) |
| void qpid::framing::AccumulatedAck::collectRanges | ( | SequenceNumberSet & | set | ) | const |
| void qpid::framing::AccumulatedAck::consolidate | ( | ) |
| bool qpid::framing::AccumulatedAck::covers | ( | SequenceNumber | tag | ) | const |
| void qpid::framing::AccumulatedAck::operator() | ( | SequenceNumber | first, | |
| SequenceNumber | last | |||
| ) | [inline] |
| void qpid::framing::AccumulatedAck::update | ( | const SequenceNumber | cumulative, | |
| const SequenceNumberSet & | range | |||
| ) |
| void qpid::framing::AccumulatedAck::update | ( | SequenceNumber | firstTag, | |
| SequenceNumber | lastTag | |||
| ) |
Referenced by operator()().
| std::list<Range> qpid::framing::AccumulatedAck::ranges |
List of individually acknowledged messages greater than the 'mark'.
Definition at line 59 of file AccumulatedAck.h.
1.5.7.1