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.