diff options
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp')
-rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp | 58 |
1 files changed, 5 insertions, 53 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp index 802279bbf9..8530051eec 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp +++ b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp @@ -23,11 +23,10 @@ #include "QueuedMessage.h" -#include "MockPersistableMessage.h" -#include "MockPersistableQueue.h" +#include "SimplePersistableMessage.h" +#include "SimplePersistableQueue.h" #include "qpid/asyncStore/AsyncStoreImpl.h" -//#include "qpid/broker/EnqueueHandle.h" namespace tests { namespace storePerftools { @@ -37,8 +36,8 @@ QueuedMessage::QueuedMessage() : m_queue(0) {} -QueuedMessage::QueuedMessage(MockPersistableQueue* q, - boost::shared_ptr<MockPersistableMessage> msg) : +QueuedMessage::QueuedMessage(SimplePersistableQueue* q, + boost::shared_ptr<SimplePersistableMessage> msg) : m_queue(q), m_msg(msg), m_enqHandle(q->getStore() ? q->getStore()->createEnqueueHandle(msg->getHandle(), q->getHandle()) : qpid::broker::EnqueueHandle(0)) @@ -62,7 +61,7 @@ QueuedMessage::operator=(const QueuedMessage& rhs) return *this; } -boost::shared_ptr<MockPersistableMessage> +boost::shared_ptr<SimplePersistableMessage> QueuedMessage::payload() const { return m_msg; @@ -80,51 +79,4 @@ QueuedMessage::enqHandle() return m_enqHandle; } -/* -QueuedMessage::QueuedMessage(boost::shared_ptr<MockPersistableMessage> msg, - qpid::broker::EnqueueHandle& enqHandle, - boost::shared_ptr<MockTransactionContext> txn) : - m_msg(msg), - m_enqHandle(enqHandle), - m_txn(txn) -{ - if (txn.get()) { - txn->addEnqueuedMsg(this); - } -} - -QueuedMessage::~QueuedMessage() -{} - -boost::shared_ptr<MockPersistableMessage> -QueuedMessage::getMessage() const -{ - return m_msg; -} - -qpid::broker::EnqueueHandle -QueuedMessage::getEnqueueHandle() const -{ - return m_enqHandle; -} - -boost::shared_ptr<MockTransactionContext> -QueuedMessage::getTransactionContext() const -{ - return m_txn; -} - -bool -QueuedMessage::isTransactional() const -{ - return m_txn.get() != 0; -} - -void -QueuedMessage::clearTransaction() -{ - m_txn.reset(static_cast<MockTransactionContext*>(0)); -} -*/ - }}} // namespace tests::storePerfTools |