#include <DeliveryRecord.h>
Public Member Functions | |
DeliveryRecord (const QueuedMessage &msg, Queue::shared_ptr queue, const std::string tag, DeliveryToken::shared_ptr token, const DeliveryId id, bool acquired, bool confirmed=false) | |
DeliveryRecord (const QueuedMessage &msg, Queue::shared_ptr queue, const DeliveryId id) | |
bool | matches (DeliveryId tag) const |
bool | matchOrAfter (DeliveryId tag) const |
bool | after (DeliveryId tag) const |
bool | coveredBy (const framing::AccumulatedAck *const range) const |
void | dequeue (TransactionContext *ctxt=0) const |
void | requeue () const |
void | release (bool setRedelivered) |
void | reject () |
void | cancel (const std::string &tag) |
void | redeliver (SemanticState *const) |
void | acquire (DeliveryIds &results) |
void | complete () |
void | accept (TransactionContext *ctxt) |
void | setEnded () |
bool | isAcquired () const |
bool | isComplete () const |
bool | isRedundant () const |
uint32_t | getCredit () const |
void | addTo (Prefetch &) const |
void | subtractFrom (Prefetch &) const |
const std::string & | getTag () const |
bool | isPull () const |
Friends | |
bool | operator< (const DeliveryRecord &, const DeliveryRecord &) |
std::ostream & | operator<< (std::ostream &, const DeliveryRecord &) |