QPID-3858: WIP - async txns for msg publish pathway, but there are some race/thread issues to sort out.

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

1 files changed, 6 insertions, 2 deletions

diff --git a/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h b/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h
index 746247e849..55504164ef 100644
--- a/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h
+++ b/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h
@@ -28,9 +28,10 @@
 
 namespace qpid {
 namespace asyncStore {
-
 class AsyncStoreImpl;
-
+}
+namespace broker {
+class AsyncResultQueue;
 }}
 
 namespace tests {
@@ -39,6 +40,7 @@ namespace asyncPerf {
 
 class SimplePersistableQueue;
 class TestOptions;
+class TxnBuffer;
 
 class MessageProducer
 {
@@ -46,6 +48,7 @@ public:
     MessageProducer(const TestOptions& perfTestParams,
                     const char* msgData,
                     qpid::asyncStore::AsyncStoreImpl* store,
+                    qpid::broker::AsyncResultQueue& arq,
                     boost::shared_ptr<SimplePersistableQueue> queue);
     virtual ~MessageProducer();
     void* runProducers();
@@ -54,6 +57,7 @@ private:
     const TestOptions& m_perfTestParams;
     const char* m_msgData;
     qpid::asyncStore::AsyncStoreImpl* m_store;
+    qpid::broker::AsyncResultQueue& m_resultQueue;
     boost::shared_ptr<SimplePersistableQueue> m_queue;
 };