1 files changed, 15 insertions, 3 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.h b/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.h
index 7f5816b6a0..5404fe9f58 100644
--- a/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.h
+++ b/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.h
@@ -26,25 +26,37 @@
 
 #include "boost/shared_ptr.hpp"
 
+namespace qpid {
+namespace asyncStore {
+class AsyncStoreImpl;
+}
+namespace broker {
+class AsyncResultQueue;
+}}
+
 namespace tests {
 namespace storePerftools {
 namespace asyncPerf {
 
-class SimplePersistableQueue;
+class SimpleQueue;
 class TestOptions;
 
 class MessageConsumer
 {
 public:
     MessageConsumer(const TestOptions& perfTestParams,
-                    boost::shared_ptr<SimplePersistableQueue> queue);
+                    qpid::asyncStore::AsyncStoreImpl* store,
+                    qpid::broker::AsyncResultQueue& arq,
+                    boost::shared_ptr<SimpleQueue> queue);
     virtual ~MessageConsumer();
 
     void* runConsumers();
     static void* startConsumers(void* ptr);
 private:
     const TestOptions& m_perfTestParams;
-    boost::shared_ptr<SimplePersistableQueue> m_queue;
+    qpid::asyncStore::AsyncStoreImpl* m_store;
+    qpid::broker::AsyncResultQueue& m_resultQueue;
+    boost::shared_ptr<SimpleQueue> m_queue;
 };
 
 }}} // namespace tests::storePerftools::asyncPerf