#include <PersistableMessage.h>
Public Types | |
typedef boost::shared_ptr < PersistableMessage > | shared_ptr |
Public Member Functions | |
virtual uint32_t | encodedHeaderSize () const =0 |
void | flush () |
bool | isContentReleased () const |
void | waitForEnqueueComplete () |
bool | isEnqueueComplete () |
void | enqueueComplete () |
void | enqueueAsync (PersistableQueue::shared_ptr queue, MessageStore *_store) |
void | enqueueAsync () |
bool | isDequeueComplete () |
void | dequeueComplete () |
void | waitForDequeueComplete () |
void | dequeueAsync (PersistableQueue::shared_ptr queue, MessageStore *_store) |
void | dequeueAsync () |
Protected Types | |
typedef std::list < boost::weak_ptr < PersistableQueue > > | syncList |
Protected Member Functions | |
void | setContentReleased () |
Protected Attributes | |
syncList | synclist |
MessageStore * | store |
bool | contentReleased |
virtual uint32_t qpid::broker::PersistableMessage::encodedHeaderSize | ( | ) | const [pure virtual] |