summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MessageStoreModule.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2006-11-30 14:48:24 +0000
committerGordon Sim <gsim@apache.org>2006-11-30 14:48:24 +0000
commit505b253590d2cf8ebfe35ccd2ff3df2443240001 (patch)
tree08896f180af647019b83d8157f578a276a9e9136 /cpp/src/qpid/broker/MessageStoreModule.cpp
parent4d7f04636758d39a3ef7250cbcc745edb3de7685 (diff)
downloadqpid-python-505b253590d2cf8ebfe35ccd2ff3df2443240001.tar.gz
Some further tweaks to MessageStore interface.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@480946 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/MessageStoreModule.cpp')
-rw-r--r--cpp/src/qpid/broker/MessageStoreModule.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/qpid/broker/MessageStoreModule.cpp b/cpp/src/qpid/broker/MessageStoreModule.cpp
index 168cb3d5bb..c0f33cb44c 100644
--- a/cpp/src/qpid/broker/MessageStoreModule.cpp
+++ b/cpp/src/qpid/broker/MessageStoreModule.cpp
@@ -38,9 +38,9 @@ void MessageStoreModule::destroy(const Queue& queue)
store->destroy(queue);
}
-void MessageStoreModule::recover(RecoveryManager& registry)
+void MessageStoreModule::recover(RecoveryManager& registry, const MessageStoreSettings* const settings)
{
- store->recover(registry);
+ store->recover(registry, settings);
}
void MessageStoreModule::stage(Message::shared_ptr& msg)
@@ -53,14 +53,14 @@ void MessageStoreModule::destroy(Message::shared_ptr& msg)
store->destroy(msg);
}
-void MessageStoreModule::appendContent(u_int64_t msgId, const std::string& data)
+void MessageStoreModule::appendContent(Message* const msg, const std::string& data)
{
- store->appendContent(msgId, data);
+ store->appendContent(msg, data);
}
-void MessageStoreModule::loadContent(u_int64_t msgId, string& data, u_int64_t offset, u_int32_t length)
+void MessageStoreModule::loadContent(Message* const msg, string& data, u_int64_t offset, u_int32_t length)
{
- store->loadContent(msgId, data, offset, length);
+ store->loadContent(msg, data, offset, length);
}
void MessageStoreModule::enqueue(TransactionContext* ctxt, Message::shared_ptr& msg, const Queue& queue, const string * const xid)