From c598f75a71e141ca8738a4c11cd8d93dd7ae5dd3 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Mon, 26 Nov 2007 21:48:37 +0000 Subject: Switched all regular PersistentMessage* and PersistentMessage& to intrusive_ptr, so as to hook into the refcount for a message while it is in the store. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@598440 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/NullMessageStore.cpp | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) (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 eb20ab6936..c0dbd9a315 100644 --- a/cpp/src/qpid/broker/NullMessageStore.cpp +++ b/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&) { QPID_LOG(info, "Can't stage message. Persistence not enabled."); } -void NullMessageStore::destroy(PersistableMessage&) +void NullMessageStore::destroy(intrusive_ptr&) { } -void NullMessageStore::appendContent(const PersistableMessage&, const string&) +void NullMessageStore::appendContent(intrusive_ptr&, 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&, 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& 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& msg, const PersistableQueue&) { - msg.dequeueComplete(); + msg->dequeueComplete(); } void NullMessageStore::flush(const qpid::broker::PersistableQueue&) -- cgit v1.2.1