diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-11-26 21:48:37 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-11-26 21:48:37 +0000 |
| commit | c598f75a71e141ca8738a4c11cd8d93dd7ae5dd3 (patch) | |
| tree | 8b3431841d1f18e0b21fc69f9a286851007b15c7 /cpp/src/qpid/broker/NullMessageStore.cpp | |
| parent | acde3eb25b94333bc7772133fa24441e1771a67c (diff) | |
| download | qpid-python-c598f75a71e141ca8738a4c11cd8d93dd7ae5dd3.tar.gz | |
Switched all regular PersistentMessage* and PersistentMessage& to intrusive_ptr<PersistentMessage>, 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
Diffstat (limited to 'cpp/src/qpid/broker/NullMessageStore.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/NullMessageStore.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
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<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&) |