summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/NullMessageStore.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/NullMessageStore.cpp')
-rw-r--r--cpp/src/qpid/broker/NullMessageStore.cpp10
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;