diff options
Diffstat (limited to 'cpp/src/tests/MessageUtils.h')
-rw-r--r-- | cpp/src/tests/MessageUtils.h | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/cpp/src/tests/MessageUtils.h b/cpp/src/tests/MessageUtils.h index 7fb1755c4b..cf0f130fa6 100644 --- a/cpp/src/tests/MessageUtils.h +++ b/cpp/src/tests/MessageUtils.h @@ -23,15 +23,16 @@ #include "qpid/broker/MessageDelivery.h" #include "qpid/framing/AMQFrame.h" -using namespace qpid::broker; -using namespace qpid::framing; +using namespace qpid; +using namespace broker; +using namespace framing; struct MessageUtils { - static Message::shared_ptr createMessage(const string& exchange, const string& routingKey, + static intrusive_ptr<Message> createMessage(const string& exchange, const string& routingKey, const string& messageId, uint64_t contentSize = 0) { - Message::shared_ptr msg(new Message()); + intrusive_ptr<Message> msg(new Message()); AMQFrame method(0, MessageTransferBody(ProtocolVersion(), 0, exchange, 0, 0)); AMQFrame header(0, AMQHeaderBody()); @@ -45,7 +46,7 @@ struct MessageUtils return msg; } - static void addContent(Message::shared_ptr msg, const string& data) + static void addContent(intrusive_ptr<Message> msg, const string& data) { AMQFrame content(0, AMQContentBody(data)); msg->getFrames().append(content); |