1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/lib/broker/Reference.cpp b/cpp/lib/broker/Reference.cpp
index a5e734d77a..dc9cb94f84 100644
--- a/cpp/lib/broker/Reference.cpp
+++ b/cpp/lib/broker/Reference.cpp
@@ -43,14 +43,14 @@ Reference&  ReferenceRegistry::get(const Reference::Id& id) {
 }
 
 void  Reference::close() {
-    for_each(transfers.begin(), transfers.end(),
+    for_each(messages.begin(), messages.end(),
              boost::bind(&Reference::complete, this, _1));
     registry->references.erase(getId());
 }
 
-void Reference::complete(TransferPtr transfer) {
-    MessageMessage::shared_ptr msg(new MessageMessage(transfer, *this));
-    registry->handler.complete(msg);
+void Reference::complete(MessagePtr message) {
+    message->setAppends(appends);
+    registry->handler.complete(message);
 }
 
 }} // namespace qpid::broker