summaryrefslogtreecommitdiff
path: root/cpp/src/tests/storePerftools/asyncPerf/SimpleMessage.cpp
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2012-07-16 13:54:11 +0000
committerKim van der Riet <kpvdr@apache.org>2012-07-16 13:54:11 +0000
commita804510d81ade0594a75b5c9b8765cafcc233245 (patch)
tree8c6be643564b6d8c88619d17de7150c98a314781 /cpp/src/tests/storePerftools/asyncPerf/SimpleMessage.cpp
parent1ab07197127e990da2c765ea0ffa5fd8ca47b7b6 (diff)
downloadqpid-python-a804510d81ade0594a75b5c9b8765cafcc233245.tar.gz
QPID-3858: Refactor to tidy up several class design issues
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1362039 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/SimpleMessage.cpp')
-rw-r--r--cpp/src/tests/storePerftools/asyncPerf/SimpleMessage.cpp15
1 files changed, 12 insertions, 3 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/SimpleMessage.cpp b/cpp/src/tests/storePerftools/asyncPerf/SimpleMessage.cpp
index 29db6ceaf2..889f7a4cdd 100644
--- a/cpp/src/tests/storePerftools/asyncPerf/SimpleMessage.cpp
+++ b/cpp/src/tests/storePerftools/asyncPerf/SimpleMessage.cpp
@@ -30,11 +30,20 @@ namespace storePerftools {
namespace asyncPerf {
SimpleMessage::SimpleMessage(const char* msgData,
+ const uint32_t msgSize) :
+ m_persistenceId(0ULL),
+ m_msg(msgData, static_cast<size_t>(msgSize)),
+ m_store(0),
+ m_msgHandle(qpid::broker::MessageHandle())
+{}
+
+SimpleMessage::SimpleMessage(const char* msgData,
const uint32_t msgSize,
- qpid::asyncStore::AsyncStoreImpl* store) :
+ qpid::broker::AsyncStore* store) :
m_persistenceId(0ULL),
m_msg(msgData, static_cast<size_t>(msgSize)),
- m_msgHandle(store ? store->createMessageHandle(this) : qpid::broker::MessageHandle(0))
+ m_store(store),
+ m_msgHandle(store ? store->createMessageHandle(this) : qpid::broker::MessageHandle())
{}
SimpleMessage::~SimpleMessage()
@@ -95,7 +104,7 @@ SimpleMessage::encodedHeaderSize() const
bool
SimpleMessage::isPersistent() const
{
- return m_msgHandle.isValid();
+ return m_store != 0;
}
uint64_t