diff options
Diffstat (limited to 'cpp/src/qpid/broker/NullMessageStore.cpp')
-rw-r--r-- | cpp/src/qpid/broker/NullMessageStore.cpp | 15 |
1 files changed, 14 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/NullMessageStore.cpp b/cpp/src/qpid/broker/NullMessageStore.cpp index 8936b0440f..401c76f5a2 100644 --- a/cpp/src/qpid/broker/NullMessageStore.cpp +++ b/cpp/src/qpid/broker/NullMessageStore.cpp @@ -49,7 +49,7 @@ public: using namespace qpid::broker; -NullMessageStore::NullMessageStore(bool _warn) : warn(_warn){} +NullMessageStore::NullMessageStore(bool _warn) : warn(_warn), nextPersistenceId(1) {} bool NullMessageStore::init(const Options* /*options*/) {return true;} @@ -57,6 +57,7 @@ void NullMessageStore::create(PersistableQueue& queue, const framing::FieldTable { QPID_LOG(info, "Queue '" << queue.getName() << "' will not be durable. Persistence not enabled."); + queue.setPersistenceId(nextPersistenceId++); } void NullMessageStore::destroy(PersistableQueue&) @@ -67,6 +68,7 @@ void NullMessageStore::create(const PersistableExchange& exchange, const framing { QPID_LOG(info, "Exchange'" << exchange.getName() << "' will not be durable. Persistence not enabled."); + exchange.setPersistenceId(nextPersistenceId++); } void NullMessageStore::destroy(const PersistableExchange& ) @@ -76,6 +78,17 @@ void NullMessageStore::bind(const PersistableExchange&, const PersistableQueue&, void NullMessageStore::unbind(const PersistableExchange&, const PersistableQueue&, const std::string&, const framing::FieldTable&){} +void NullMessageStore::create(const PersistableConfig& config) +{ + QPID_LOG(info, "Persistence not enabled, configuration not stored."); + config.setPersistenceId(nextPersistenceId++); +} + +void NullMessageStore::destroy(const PersistableConfig&) +{ + QPID_LOG(info, "Persistence not enabled, configuration not stored."); +} + void NullMessageStore::recover(RecoveryManager&) { QPID_LOG(info, "Persistence not enabled, no recovery attempted."); |