- added init for dir and async options for store

- added flush for queue for async processing



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@586207 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 10 insertions, 0 deletions

diff --git a/cpp/src/qpid/broker/MessageStoreModule.cpp b/cpp/src/qpid/broker/MessageStoreModule.cpp
index c87503279e..384dfff6dc 100644
--- a/cpp/src/qpid/broker/MessageStoreModule.cpp
+++ b/cpp/src/qpid/broker/MessageStoreModule.cpp
@@ -28,6 +28,11 @@ MessageStoreModule::MessageStoreModule(const std::string& name) : store(name)
 {
 }
 
+void MessageStoreModule::init(const std::string& dir, const bool async)
+{
+	store->init(dir, async);
+}
+
 void MessageStoreModule::create(PersistableQueue& queue)
 {
     store->create(queue);
@@ -95,6 +100,11 @@ void MessageStoreModule::dequeue(TransactionContext* ctxt, PersistableMessage& m
     store->dequeue(ctxt, msg, queue);
 }
 
+void MessageStoreModule::flush(const qpid::broker::PersistableQueue& queue)
+{
+    store->flush(queue);
+}
+
 u_int32_t MessageStoreModule::outstandingQueueAIO(const PersistableQueue& queue)
 {
     return store->outstandingQueueAIO(queue);