QPID-920: converted c++ client to use final 0-10 protocol

* connection handler converted to using invoker & proxy and updated to final method defs
* SessionCore & ExecutionHandler replace by SessionImpl
* simplified handling of completion & results, removed handling of responses



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@649915 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 8 insertions, 7 deletions

diff --git a/cpp/src/qpid/management/ManagementAgent.cpp b/cpp/src/qpid/management/ManagementAgent.cpp
index cace04bef5..769593c8d2 100644
--- a/cpp/src/qpid/management/ManagementAgent.cpp
+++ b/cpp/src/qpid/management/ManagementAgent.cpp
@@ -24,6 +24,7 @@
 #include "qpid/log/Statement.h"
 #include <qpid/broker/Message.h>
 #include <qpid/broker/MessageDelivery.h>
+#include "qpid/framing/MessageXTransferBody.h"
 #include <list>
 #include <iostream>
 #include <fstream>
@@ -217,7 +218,7 @@ void ManagementAgent::SendBuffer (Buffer&  buf,
         return;
 
     intrusive_ptr<Message> msg (new Message ());
-    AMQFrame method (in_place<MessageTransferBody>(
+    AMQFrame method (in_place<MessageXTransferBody>(
                          ProtocolVersion(), 0, exchange->getName (), 0, 0));
     AMQFrame header (in_place<AMQHeaderBody>());
     AMQFrame content(in_place<AMQContentBody>());
@@ -232,8 +233,8 @@ void ManagementAgent::SendBuffer (Buffer&  buf,
     msg->getFrames().append(method);
     msg->getFrames().append(header);
 
-    MessageProperties* props =
-        msg->getFrames().getHeaders()->get<MessageProperties>(true);
+    PreviewMessageProperties* props =
+        msg->getFrames().getHeaders()->get<PreviewMessageProperties>(true);
     props->setContentLength(length);
     msg->getFrames().append(content);
 
@@ -393,8 +394,8 @@ void ManagementAgent::dispatchMethod (Message&      msg,
     uint64_t   objId = inBuffer.getLongLong ();
     string     replyToKey;
 
-    const framing::MessageProperties* p =
-        msg.getFrames().getHeaders()->get<framing::MessageProperties>();
+    const framing::PreviewMessageProperties* p =
+        msg.getFrames().getHeaders()->get<framing::PreviewMessageProperties>();
     if (p && p->hasReplyTo())
     {
         const framing::ReplyTo& rt = p->getReplyTo ();
@@ -600,8 +601,8 @@ void ManagementAgent::dispatchAgentCommand (Message& msg)
     uint32_t sequence;
     string   replyToKey;
 
-    const framing::MessageProperties* p =
-        msg.getFrames().getHeaders()->get<framing::MessageProperties>();
+    const framing::PreviewMessageProperties* p =
+        msg.getFrames().getHeaders()->get<framing::PreviewMessageProperties>();
     if (p && p->hasReplyTo())
     {
         const framing::ReplyTo& rt = p->getReplyTo ();