diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/NullMessageStore.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/NullMessageStore.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/qpid/cpp/src/qpid/broker/NullMessageStore.cpp b/qpid/cpp/src/qpid/broker/NullMessageStore.cpp index eb20ab6936..c0dbd9a315 100644 --- a/qpid/cpp/src/qpid/broker/NullMessageStore.cpp +++ b/qpid/cpp/src/qpid/broker/NullMessageStore.cpp @@ -79,34 +79,34 @@ void NullMessageStore::recover(RecoveryManager&) QPID_LOG(info, "Persistence not enabled, no recovery attempted."); } -void NullMessageStore::stage(PersistableMessage&) +void NullMessageStore::stage(intrusive_ptr<PersistableMessage>&) { QPID_LOG(info, "Can't stage message. Persistence not enabled."); } -void NullMessageStore::destroy(PersistableMessage&) +void NullMessageStore::destroy(intrusive_ptr<PersistableMessage>&) { } -void NullMessageStore::appendContent(const PersistableMessage&, const string&) +void NullMessageStore::appendContent(intrusive_ptr<const PersistableMessage>&, const string&) { QPID_LOG(info, "Can't append content. Persistence not enabled."); } -void NullMessageStore::loadContent(const qpid::broker::PersistableQueue&, const PersistableMessage&, string&, uint64_t, uint32_t) +void NullMessageStore::loadContent(const qpid::broker::PersistableQueue&, intrusive_ptr<const PersistableMessage>&, string&, uint64_t, uint32_t) { QPID_LOG(info, "Can't load content. Persistence not enabled."); } -void NullMessageStore::enqueue(TransactionContext*, PersistableMessage& msg, const PersistableQueue& queue) +void NullMessageStore::enqueue(TransactionContext*, intrusive_ptr<PersistableMessage>& msg, const PersistableQueue& queue) { - msg.enqueueComplete(); + msg->enqueueComplete(); QPID_LOG(info, "Message is not durably recorded on '" << queue.getName() << "'. Persistence not enabled."); } -void NullMessageStore::dequeue(TransactionContext*, PersistableMessage& msg, const PersistableQueue&) +void NullMessageStore::dequeue(TransactionContext*, intrusive_ptr<PersistableMessage>& msg, const PersistableQueue&) { - msg.dequeueComplete(); + msg->dequeueComplete(); } void NullMessageStore::flush(const qpid::broker::PersistableQueue&) |