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/qpid@524139 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 4 deletions

diff --git a/cpp/lib/broker/LazyLoadedContent.cpp b/cpp/lib/broker/LazyLoadedContent.cpp
index 131943b448..9810ee671c 100644
--- a/cpp/lib/broker/LazyLoadedContent.cpp
+++ b/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));
     }
 }