summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MessageStoreModule.cpp
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2007-11-08 18:46:53 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2007-11-08 18:46:53 +0000
commitd9ba9eae91290581b62f67239300897a96827e83 (patch)
tree67ea6a18828a42cafea5fce43b36b8b5f7c5becf /cpp/src/qpid/broker/MessageStoreModule.cpp
parent10a794c9d2fede2a0db9cf80e95f19d56e931196 (diff)
downloadqpid-python-d9ba9eae91290581b62f67239300897a96827e83.tar.gz
- enable the ability to lazy load from async store
- the ci has a raw ptr for Queue in QueuedMessage, if any has any concerns, ping me and I will convert it to an auto_ptr Carl. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@593251 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/MessageStoreModule.cpp')
-rw-r--r--cpp/src/qpid/broker/MessageStoreModule.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/MessageStoreModule.cpp b/cpp/src/qpid/broker/MessageStoreModule.cpp
index 1ddad65c56..adb41f6094 100644
--- a/cpp/src/qpid/broker/MessageStoreModule.cpp
+++ b/cpp/src/qpid/broker/MessageStoreModule.cpp
@@ -71,7 +71,7 @@ void MessageStoreModule::recover(RecoveryManager& registry)
store->recover(registry);
}
-void MessageStoreModule::stage(PersistableMessage& msg)
+void MessageStoreModule::stage( PersistableMessage& msg)
{
store->stage(msg);
}
@@ -86,9 +86,10 @@ void MessageStoreModule::appendContent(const PersistableMessage& msg, const std:
store->appendContent(msg, data);
}
-void MessageStoreModule::loadContent(const PersistableMessage& msg, string& data, uint64_t offset, uint32_t length)
+void MessageStoreModule::loadContent(const qpid::broker::PersistableQueue& queue,
+ const PersistableMessage& msg, string& data, uint64_t offset, uint32_t length)
{
- store->loadContent(msg, data, offset, length);
+ store->loadContent(queue, msg, data, offset, length);
}
void MessageStoreModule::enqueue(TransactionContext* ctxt, PersistableMessage& msg, const PersistableQueue& queue)