From bfcdddb9af408b62ae4d2689611be8763df45e0c Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Fri, 19 Oct 2007 01:33:24 +0000 Subject: - 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 --- cpp/src/qpid/broker/NullMessageStore.cpp | 10 ++++++++++ 1 file changed, 10 insertions(+) (limited to 'cpp/src/qpid/broker/NullMessageStore.cpp') 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; -- cgit v1.2.1