Updated message.transfer encoding to use header and content segments (including new structs).

Unified more between the basic and message classes messages.



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

1 files changed, 7 insertions, 5 deletions

diff --git a/cpp/src/tests/TxAckTest.cpp b/cpp/src/tests/TxAckTest.cpp
index 24e8aac701..89a907d495 100644
--- a/cpp/src/tests/TxAckTest.cpp
+++ b/cpp/src/tests/TxAckTest.cpp
@@ -68,11 +68,13 @@ public:
     TxAckTest() : acked(0), queue(new Queue("my_queue", false, &store, 0)), op(acked, deliveries)
     {
         for(int i = 0; i < 10; i++){
-            Message::shared_ptr msg(
-                new BasicMessage(0, "exchange", "routing_key", false, false));
-            AMQHeaderBody body(BASIC);
-            msg->setHeader(&body);
-            msg->getHeaderProperties()->setDeliveryMode(PERSISTENT);
+            Message::shared_ptr msg(new Message());
+            AMQFrame method(0, MessageTransferBody(ProtocolVersion(), 0, "exchange", 0, 0));
+            AMQFrame header(0, AMQHeaderBody());
+            msg->getFrames().append(method);
+            msg->getFrames().append(header);
+            msg->getProperties<DeliveryProperties>()->setDeliveryMode(PERSISTENT);
+            msg->getProperties<DeliveryProperties>()->setRoutingKey("routing_key");
             messages.push_back(msg);
             deliveries.push_back(DeliveryRecord(msg, queue, "xyz", (i+1)));
         }