00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022 #include "qpid/broker/Message.h"
00023 #include "qpid/broker/MessageDelivery.h"
00024 #include "qpid/framing/AMQFrame.h"
00025 #include "qpid/framing/MessageTransferBody.h"
00026 #include "qpid/framing/Uuid.h"
00027
00028 using namespace qpid;
00029 using namespace broker;
00030 using namespace framing;
00031
00032 struct MessageUtils
00033 {
00034 static boost::intrusive_ptr<Message> createMessage(const string& exchange="", const string& routingKey="",
00035 const Uuid& messageId=Uuid(true), uint64_t contentSize = 0)
00036 {
00037 boost::intrusive_ptr<Message> msg(new Message());
00038
00039 AMQFrame method(in_place<MessageTransferBody>(ProtocolVersion(), exchange, 0, 0));
00040 AMQFrame header(in_place<AMQHeaderBody>());
00041
00042 msg->getFrames().append(method);
00043 msg->getFrames().append(header);
00044 MessageProperties* props = msg->getFrames().getHeaders()->get<MessageProperties>(true);
00045 props->setContentLength(contentSize);
00046 props->setMessageId(messageId);
00047 msg->getFrames().getHeaders()->get<DeliveryProperties>(true)->setRoutingKey(routingKey);
00048 return msg;
00049 }
00050
00051 static void addContent(boost::intrusive_ptr<Message> msg, const string& data)
00052 {
00053 AMQFrame content(in_place<AMQContentBody>(data));
00054 msg->getFrames().append(content);
00055 }
00056 };