diff options
Diffstat (limited to 'cpp/src/qpid/broker/PersistableMessage.h')
-rw-r--r-- | cpp/src/qpid/broker/PersistableMessage.h | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/PersistableMessage.h b/cpp/src/qpid/broker/PersistableMessage.h index 6b6e9a7007..59fa2e3d95 100644 --- a/cpp/src/qpid/broker/PersistableMessage.h +++ b/cpp/src/qpid/broker/PersistableMessage.h @@ -68,10 +68,15 @@ class PersistableMessage : public Persistable syncList synclist; protected: - MessageStore* store; - + /** Called when all enqueues are complete for this message. */ + virtual void allEnqueuesComplete() = 0; + /** Called when all dequeues are complete for this message. */ + virtual void allDequeuesComplete() = 0; + void setContentReleased(); + MessageStore* store; + public: typedef boost::shared_ptr<PersistableMessage> shared_ptr; |