summaryrefslogtreecommitdiff
path: root/qpid/cpp/lib/broker/LazyLoadedContent.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-03-30 15:50:07 +0000
committerGordon Sim <gsim@apache.org>2007-03-30 15:50:07 +0000
commit72bca07ee53fb9476f268133f244d55d8f53d3b9 (patch)
tree6e8400200b22188899144a025ecb1a6c5922cc7b /qpid/cpp/lib/broker/LazyLoadedContent.cpp
parent61c7761f005dacfc5938a4d4d25b7120a8e21620 (diff)
downloadqpid-python-72bca07ee53fb9476f268133f244d55d8f53d3b9.tar.gz
Refactored the MessageStore interface to restrict visibility of broker core from store implementations.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@524139 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/lib/broker/LazyLoadedContent.cpp')
-rw-r--r--qpid/cpp/lib/broker/LazyLoadedContent.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/qpid/cpp/lib/broker/LazyLoadedContent.cpp b/qpid/cpp/lib/broker/LazyLoadedContent.cpp
index 131943b448..9810ee671c 100644
--- a/qpid/cpp/lib/broker/LazyLoadedContent.cpp
+++ b/qpid/cpp/lib/broker/LazyLoadedContent.cpp
@@ -27,7 +27,7 @@ using namespace qpid::framing;
LazyLoadedContent::~LazyLoadedContent()
{
- store->destroy(msg);
+ store->destroy(*msg);
}
LazyLoadedContent::LazyLoadedContent(MessageStore* const _store, Message* const _msg, uint64_t _expectedSize) :
@@ -35,7 +35,7 @@ LazyLoadedContent::LazyLoadedContent(MessageStore* const _store, Message* const
void LazyLoadedContent::add(AMQContentBody::shared_ptr data)
{
- store->appendContent(msg, data->getData());
+ store->appendContent(*msg, data->getData());
}
uint32_t LazyLoadedContent::size()
@@ -50,13 +50,13 @@ void LazyLoadedContent::send(ChannelAdapter& channel, uint32_t framesize)
{
uint64_t remaining = expectedSize - offset;
string data;
- store->loadContent(msg, data, offset,
+ store->loadContent(*msg, data, offset,
remaining > framesize ? framesize : remaining);
channel.send(new AMQContentBody(data));
}
} else {
string data;
- store->loadContent(msg, data, 0, expectedSize);
+ store->loadContent(*msg, data, 0, expectedSize);
channel.send(new AMQContentBody(data));
}
}