diff options
Diffstat (limited to 'cpp/src/qpid/broker/LazyLoadedContent.cpp')
-rw-r--r-- | cpp/src/qpid/broker/LazyLoadedContent.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/LazyLoadedContent.cpp b/cpp/src/qpid/broker/LazyLoadedContent.cpp index 80d06ebf2b..b8b5b37f45 100644 --- a/cpp/src/qpid/broker/LazyLoadedContent.cpp +++ b/cpp/src/qpid/broker/LazyLoadedContent.cpp @@ -33,7 +33,7 @@ LazyLoadedContent::~LazyLoadedContent() LazyLoadedContent::LazyLoadedContent(MessageStore* const _store, Message* const _msg, uint64_t _expectedSize) : store(_store), msg(_msg), expectedSize(_expectedSize) {} -void LazyLoadedContent::add(AMQContentBody::shared_ptr data) +void LazyLoadedContent::add(AMQContentBody* data) { store->appendContent(*msg, data->getData()); } @@ -52,12 +52,12 @@ void LazyLoadedContent::send(ChannelAdapter& channel, uint32_t framesize) string data; store->loadContent(*msg, data, offset, remaining > framesize ? framesize : remaining); - channel.send(make_shared_ptr(new AMQContentBody(data))); + channel.send(AMQContentBody(data)); } } else { string data; store->loadContent(*msg, data, 0, expectedSize); - channel.send(make_shared_ptr(new AMQContentBody(data))); + channel.send(AMQContentBody(data)); } } |