* 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, 7 insertions, 8 deletions

diff --git a/cpp/lib/broker/MessageHandlerImpl.cpp b/cpp/lib/broker/MessageHandlerImpl.cpp
index 5f5e9b84e7..49c4153185 100644
--- a/cpp/lib/broker/MessageHandlerImpl.cpp
+++ b/cpp/lib/broker/MessageHandlerImpl.cpp
@@ -217,14 +217,13 @@ MessageHandlerImpl::transfer(const MethodContext& context,
     MessageTransferBody::shared_ptr transfer(
         boost::shared_polymorphic_downcast<MessageTransferBody>(
             context.methodBody));
-    if (body.isInline()) {
-        Message::shared_ptr msg(new MessageMessage(transfer));
-        channel.handleInlineTransfer(msg, exchange);
-    }
-    else {
-        // Add to reference.
-        references.get(body.getValue()).transfer(transfer);
-    }
+    MessageMessage::shared_ptr message(
+        new MessageMessage(&connection, transfer));
+    
+    if (body.isInline()) 
+        channel.handleInlineTransfer(message, exchange);
+    else 
+        references.get(body.getValue()).addMessage(message);
     client.ok(context);
 }