- 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/NullMessageStore.cpp b/cpp/src/qpid/broker/NullMessageStore.cpp
index 843d31654b..b8e4950287 100644
--- a/cpp/src/qpid/broker/NullMessageStore.cpp
+++ b/cpp/src/qpid/broker/NullMessageStore.cpp
@@ -49,6 +49,11 @@ using namespace qpid::broker;
 
 NullMessageStore::NullMessageStore(bool _warn) : warn(_warn){}
 
+void NullMessageStore::init(const std::string& /*dir*/, const bool /*async*/)
+{
+    QPID_LOG(info, "Can't init, store not enabled");
+}
+
 void NullMessageStore::create(PersistableQueue& queue)
 {
     QPID_LOG(info, "Can't create durable queue '" << queue.getName() << "'. Persistence not enabled.");
@@ -109,6 +114,11 @@ void NullMessageStore::dequeue(TransactionContext*, PersistableMessage& msg, con
     QPID_LOG(info, "Can't dequeue message from '" << queue.getName() << "'. Persistence not enabled.");
 }
 
+void NullMessageStore::flush(const qpid::broker::PersistableQueue& queue)
+{
+    QPID_LOG(info, "Can't flush. Persistence not enabled queue-" << queue.getName());
+}
+
 u_int32_t NullMessageStore::outstandingQueueAIO(const PersistableQueue& )
 {
     return 0;