summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/PersistableQueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/PersistableQueue.h')
-rw-r--r--cpp/src/qpid/broker/PersistableQueue.h13
1 files changed, 8 insertions, 5 deletions
diff --git a/cpp/src/qpid/broker/PersistableQueue.h b/cpp/src/qpid/broker/PersistableQueue.h
index 655d26bc74..ed8c193245 100644
--- a/cpp/src/qpid/broker/PersistableQueue.h
+++ b/cpp/src/qpid/broker/PersistableQueue.h
@@ -23,12 +23,15 @@
*/
#include <string>
+#include "qpid/broker/AsyncStore.h"
#include "qpid/broker/Persistable.h"
+#include "qpid/broker/QueueHandle.h"
#include "qpid/management/Manageable.h"
#include <boost/shared_ptr.hpp>
namespace qpid {
namespace broker {
+class AsyncResultHandle;
/**
@@ -48,7 +51,7 @@ public:
* The interface queues must expose to the MessageStore in order to be
* persistable.
*/
-class PersistableQueue : public Persistable
+class PersistableQueue : public Persistable, public DataSource
{
public:
typedef boost::shared_ptr<PersistableQueue> shared_ptr;
@@ -62,14 +65,14 @@ public:
virtual void setExternalQueueStore(ExternalQueueStore* inst) = 0;
virtual void flush() = 0;
- inline ExternalQueueStore* getExternalQueueStore() const {return externalQueueStore;};
+ inline ExternalQueueStore* getExternalQueueStore() const {return externalQueueStore;}
+ inline QueueHandle& getQueueHandle() { return queueHandle; }
- PersistableQueue():externalQueueStore(NULL){
- };
+ PersistableQueue():externalQueueStore(NULL) {}
protected:
ExternalQueueStore* externalQueueStore;
-
+ QueueHandle queueHandle;
};
}}