diff options
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h')
-rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h b/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h index 127408e3db..6f98d03503 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h +++ b/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.h @@ -27,19 +27,17 @@ #include "boost/shared_ptr.hpp" namespace qpid { -namespace asyncStore { -class AsyncStoreImpl; -} namespace broker { class AsyncResultQueue; -class TxnBuffer; +class AsyncStore; +class SimpleQueue; +class SimpleTxnBuffer; }} namespace tests { namespace storePerftools { namespace asyncPerf { -class SimpleQueue; class TestOptions; class MessageProducer @@ -47,18 +45,18 @@ class MessageProducer public: MessageProducer(const TestOptions& perfTestParams, const char* msgData, - qpid::asyncStore::AsyncStoreImpl* store, + qpid::broker::AsyncStore* store, qpid::broker::AsyncResultQueue& arq, - boost::shared_ptr<SimpleQueue> queue); + boost::shared_ptr<qpid::broker::SimpleQueue> queue); virtual ~MessageProducer(); void* runProducers(); static void* startProducers(void* ptr); private: const TestOptions& m_perfTestParams; const char* m_msgData; - qpid::asyncStore::AsyncStoreImpl* m_store; + qpid::broker::AsyncStore* m_store; qpid::broker::AsyncResultQueue& m_resultQueue; - boost::shared_ptr<SimpleQueue> m_queue; + boost::shared_ptr<qpid::broker::SimpleQueue> m_queue; }; }}} // namespace tests::storePerftools::asyncPerf |