* broker/BrokerMessage.cpp: Added ConnectionToken publisher.

* cpp/lib/broker/BrokerMessageMessage.cpp:
 - Added ConnectionToken publisher.
 - Implemented getDeliveryMode, getApplicationHeaders

* cpp/lib/broker/Reference.cpp: Holds MessageMessage instead of just
  MessageTransferBody.


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@504485 13f79535-47bb-0310-9956-ffa450edef68

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