summaryrefslogtreecommitdiff
path: root/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2012-06-08 19:09:23 +0000
committerKim van der Riet <kpvdr@apache.org>2012-06-08 19:09:23 +0000
commit8d826b88be96ed9605fc267ccbe5be8bb8c95e76 (patch)
tree649d3a3b7631eb9b5f5dd9f62615379f198bd65d /cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp
parent4ca527d39453bcd49374c23ec01a4eacf615b650 (diff)
downloadqpid-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.cpp58
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