From 4780580874e8d6a3e3590fa5fdf8a088310b20ae Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Sun, 20 Apr 2008 12:10:37 +0000 Subject: 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@649915 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/TxAckTest.cpp | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) (limited to 'qpid/cpp/src/tests/TxAckTest.cpp') diff --git a/qpid/cpp/src/tests/TxAckTest.cpp b/qpid/cpp/src/tests/TxAckTest.cpp index 89b98cb93c..b86f3d75e0 100644 --- a/qpid/cpp/src/tests/TxAckTest.cpp +++ b/qpid/cpp/src/tests/TxAckTest.cpp @@ -18,6 +18,7 @@ * under the License. * */ +#include "MessageUtils.h" #include "qpid/broker/NullMessageStore.h" #include "qpid/broker/RecoveryManager.h" #include "qpid/broker/TxAck.h" @@ -69,14 +70,8 @@ public: TxAckTest() : acked(0), queue(new Queue("my_queue", false, &store, 0)), op(acked, deliveries) { for(int i = 0; i < 10; i++){ - intrusive_ptr msg(new Message()); - AMQFrame method(in_place( - ProtocolVersion(), 0, "exchange", 0, 0)); - AMQFrame header(in_place()); - msg->getFrames().append(method); - msg->getFrames().append(header); + intrusive_ptr msg(MessageUtils::createMessage("exchange", "routing_key")); msg->getProperties()->setDeliveryMode(PERSISTENT); - msg->getProperties()->setRoutingKey("routing_key"); messages.push_back(msg); QueuedMessage qm(queue.get()); qm.payload = msg; -- cgit v1.2.1