summaryrefslogtreecommitdiff
path: root/cpp/tests/TxAckTest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/tests/TxAckTest.cpp')
-rw-r--r--cpp/tests/TxAckTest.cpp7
1 files changed, 5 insertions, 2 deletions
diff --git a/cpp/tests/TxAckTest.cpp b/cpp/tests/TxAckTest.cpp
index a6fe0f1010..07381d187d 100644
--- a/cpp/tests/TxAckTest.cpp
+++ b/cpp/tests/TxAckTest.cpp
@@ -25,6 +25,7 @@
#include <iostream>
#include <list>
#include <vector>
+#include "DummyChannel.h"
using std::list;
using std::vector;
@@ -44,7 +45,7 @@ class TxAckTest : public CppUnit::TestCase
dequeued.push_back(std::pair<Message*, const string*>(msg, xid));
}
- TestMessageStore() : NullMessageStore(false) {}
+ TestMessageStore() : NullMessageStore() {}
~TestMessageStore(){}
};
@@ -69,7 +70,9 @@ public:
TxAckTest() : queue(new Queue("my_queue", false, &store, 0)), op(acked, deliveries, &xid)
{
for(int i = 0; i < 10; i++){
- Message::shared_ptr msg(new BasicMessage(0, "exchange", "routing_key", false, false));
+ Message::shared_ptr msg(
+ new BasicMessage(0, "exchange", "routing_key", false, false,
+ DummyChannel::basicGetBody()));
msg->setHeader(AMQHeaderBody::shared_ptr(new AMQHeaderBody(BASIC)));
msg->getHeaderProperties()->setDeliveryMode(PERSISTENT);
messages.push_back(msg);