From b95f9427ede4a2045ac6424a6341de9185a13602 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Thu, 21 Jun 2012 12:09:00 +0000 Subject: QPID-3858: WIP: New classes for transactional consumption of messages git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1352509 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp') diff --git a/cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp b/cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp index 7941e761ca..e3fdd1c44d 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp +++ b/cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp @@ -25,7 +25,7 @@ #include "MessageConsumer.h" #include "MessageProducer.h" -#include "SimplePersistableQueue.h" +#include "SimpleQueue.h" #include "tests/storePerftools/version.h" #include "tests/storePerftools/common/ScopedTimer.h" @@ -87,7 +87,7 @@ PerfTest::run() reinterpret_cast(mp.get()))); threads.push_back(tp); } - boost::shared_ptr mc(new MessageConsumer(m_testOpts, m_queueList[q])); + boost::shared_ptr mc(new MessageConsumer(m_testOpts, m_store, m_resultQueue, m_queueList[q])); m_consumers.push_back(mc); for (uint16_t dt = 0; dt < m_testOpts.m_numDeqThreadsPerQueue; ++dt) { // TODO - replace with qpid threads boost::shared_ptr tp(new tests::storePerftools::common::Thread(mc->startConsumers, @@ -138,7 +138,7 @@ PerfTest::prepareQueues() for (uint16_t i = 0; i < m_testOpts.m_numQueues; ++i) { std::ostringstream qname; qname << "queue_" << std::setw(4) << std::setfill('0') << i; - boost::shared_ptr mpq(new SimplePersistableQueue(qname.str(), m_queueArgs, m_store, m_resultQueue)); + boost::shared_ptr mpq(new SimpleQueue(qname.str(), m_queueArgs, m_store, m_resultQueue)); mpq->asyncCreate(); m_queueList.push_back(mpq); } -- cgit v1.2.1