summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MessageStoreModule.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/MessageStoreModule.h')
-rw-r--r--cpp/src/qpid/broker/MessageStoreModule.h4
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/MessageStoreModule.h b/cpp/src/qpid/broker/MessageStoreModule.h
index a983957b5e..43772bf98c 100644
--- a/cpp/src/qpid/broker/MessageStoreModule.h
+++ b/cpp/src/qpid/broker/MessageStoreModule.h
@@ -38,6 +38,7 @@ class MessageStoreModule : public MessageStore
public:
MessageStoreModule(const std::string& name);
+ void init(const std::string& dir, const bool async);
std::auto_ptr<TransactionContext> begin();
std::auto_ptr<TPCTransactionContext> begin(const std::string& xid);
void prepare(TPCTransactionContext& txn);
@@ -62,7 +63,8 @@ public:
void enqueue(TransactionContext* ctxt, PersistableMessage& msg, const PersistableQueue& queue);
void dequeue(TransactionContext* ctxt, PersistableMessage& msg, const PersistableQueue& queue);
u_int32_t outstandingQueueAIO(const PersistableQueue& queue);
-
+ void flush(const qpid::broker::PersistableQueue& queue);
+
~MessageStoreModule(){}
};