summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/management
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-04-22 16:11:34 +0000
committerRafael H. Schloming <rhs@apache.org>2008-04-22 16:11:34 +0000
commite06aa805cfe24b8edf619a6a535883f94589ac35 (patch)
tree4b886461816ca97127aae8a9639ddad74d77bd46 /cpp/src/qpid/management
parent61959e29ee69f9cebb61b845272eededaec6f11e (diff)
downloadqpid-python-e06aa805cfe24b8edf619a6a535883f94589ac35.tar.gz
QPID-947: update cpp and python management to 0-10 final
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@650565 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/management')
-rw-r--r--cpp/src/qpid/management/ManagementAgent.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/cpp/src/qpid/management/ManagementAgent.cpp b/cpp/src/qpid/management/ManagementAgent.cpp
index 769593c8d2..9b4290232d 100644
--- a/cpp/src/qpid/management/ManagementAgent.cpp
+++ b/cpp/src/qpid/management/ManagementAgent.cpp
@@ -24,7 +24,7 @@
#include "qpid/log/Statement.h"
#include <qpid/broker/Message.h>
#include <qpid/broker/MessageDelivery.h>
-#include "qpid/framing/MessageXTransferBody.h"
+#include "qpid/framing/MessageTransferBody.h"
#include <list>
#include <iostream>
#include <fstream>
@@ -218,8 +218,8 @@ void ManagementAgent::SendBuffer (Buffer& buf,
return;
intrusive_ptr<Message> msg (new Message ());
- AMQFrame method (in_place<MessageXTransferBody>(
- ProtocolVersion(), 0, exchange->getName (), 0, 0));
+ AMQFrame method (in_place<MessageTransferBody>(
+ ProtocolVersion(), exchange->getName (), 0, 0));
AMQFrame header (in_place<AMQHeaderBody>());
AMQFrame content(in_place<AMQContentBody>());
@@ -233,8 +233,8 @@ void ManagementAgent::SendBuffer (Buffer& buf,
msg->getFrames().append(method);
msg->getFrames().append(header);
- PreviewMessageProperties* props =
- msg->getFrames().getHeaders()->get<PreviewMessageProperties>(true);
+ MessageProperties* props =
+ msg->getFrames().getHeaders()->get<MessageProperties>(true);
props->setContentLength(length);
msg->getFrames().append(content);
@@ -394,8 +394,8 @@ void ManagementAgent::dispatchMethod (Message& msg,
uint64_t objId = inBuffer.getLongLong ();
string replyToKey;
- const framing::PreviewMessageProperties* p =
- msg.getFrames().getHeaders()->get<framing::PreviewMessageProperties>();
+ const framing::MessageProperties* p =
+ msg.getFrames().getHeaders()->get<framing::MessageProperties>();
if (p && p->hasReplyTo())
{
const framing::ReplyTo& rt = p->getReplyTo ();
@@ -601,8 +601,8 @@ void ManagementAgent::dispatchAgentCommand (Message& msg)
uint32_t sequence;
string replyToKey;
- const framing::PreviewMessageProperties* p =
- msg.getFrames().getHeaders()->get<framing::PreviewMessageProperties>();
+ const framing::MessageProperties* p =
+ msg.getFrames().getHeaders()->get<framing::MessageProperties>();
if (p && p->hasReplyTo())
{
const framing::ReplyTo& rt = p->getReplyTo ();