diff options
author | Kim van der Riet <kpvdr@apache.org> | 2012-06-08 19:09:23 +0000 |
---|---|---|
committer | Kim van der Riet <kpvdr@apache.org> | 2012-06-08 19:09:23 +0000 |
commit | 8d826b88be96ed9605fc267ccbe5be8bb8c95e76 (patch) | |
tree | 649d3a3b7631eb9b5f5dd9f62615379f198bd65d /cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp | |
parent | 4ca527d39453bcd49374c23ec01a4eacf615b650 (diff) | |
download | qpid-python-8d826b88be96ed9605fc267ccbe5be8bb8c95e76.tar.gz |
QPID-3858: WIP - tidy-up: renamed Mock* to Simple* (as the classes are not empty mocks)
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1348194 13f79535-47bb-0310-9956-ffa450edef68
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 |