diff options
Diffstat (limited to 'cpp/src/qpid/broker/NullMessageStore.cpp')
-rw-r--r-- | cpp/src/qpid/broker/NullMessageStore.cpp | 10 |
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; |