WIP - transactional consume path completed, still some testing to be done.

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1353703 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 0 deletions

diff --git a/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.h b/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.h
index 5404fe9f58..e733990cf7 100644
--- a/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.h
+++ b/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.h
@@ -25,6 +25,7 @@
 #define tests_storePerftools_asyncPerf_MessageConsumer_h_
 
 #include "boost/shared_ptr.hpp"
+#include <deque>
 
 namespace qpid {
 namespace asyncStore {
@@ -38,6 +39,7 @@ namespace tests {
 namespace storePerftools {
 namespace asyncPerf {
 
+class DeliveryRecord;
 class SimpleQueue;
 class TestOptions;
 
@@ -49,6 +51,8 @@ public:
                     qpid::broker::AsyncResultQueue& arq,
                     boost::shared_ptr<SimpleQueue> queue);
     virtual ~MessageConsumer();
+    void record(boost::shared_ptr<DeliveryRecord> dr);
+    void dequeueComplete();
 
     void* runConsumers();
     static void* startConsumers(void* ptr);
@@ -57,6 +61,7 @@ private:
     qpid::asyncStore::AsyncStoreImpl* m_store;
     qpid::broker::AsyncResultQueue& m_resultQueue;
     boost::shared_ptr<SimpleQueue> m_queue;
+    std::deque<boost::shared_ptr<DeliveryRecord> > m_unacked;
 };
 
 }}} // namespace tests::storePerftools::asyncPerf