1 files changed, 52 insertions, 0 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/PersistableQueuedMessage.cpp b/cpp/src/tests/storePerftools/asyncPerf/PersistableQueuedMessage.cpp
new file mode 100644
index 0000000000..2eba7d5be5
--- /dev/null
+++ b/cpp/src/tests/storePerftools/asyncPerf/PersistableQueuedMessage.cpp
@@ -0,0 +1,52 @@
+#include "PersistableQueuedMessage.h"
+
+#include "SimpleQueue.h"
+#include "SimpleMessage.h"
+
+namespace tests {
+namespace storePerftools {
+namespace asyncPerf {
+
+PersistableQueuedMessage::PersistableQueuedMessage()
+{}
+
+PersistableQueuedMessage::PersistableQueuedMessage(SimpleQueue* q,
+                                                   boost::intrusive_ptr<SimpleMessage> msg) :
+        QueuedMessage(q, msg),
+        m_enqHandle(q->getStore()->createEnqueueHandle(msg->getHandle(), q->getHandle()))
+{}
+
+PersistableQueuedMessage::PersistableQueuedMessage(const PersistableQueuedMessage& pm) :
+        QueuedMessage(pm),
+        m_enqHandle(pm.m_enqHandle)
+{}
+
+PersistableQueuedMessage::PersistableQueuedMessage(PersistableQueuedMessage* const pm) :
+        QueuedMessage(pm),
+        m_enqHandle(pm->m_enqHandle)
+{}
+
+PersistableQueuedMessage::~PersistableQueuedMessage()
+{}
+
+PersistableQueuedMessage&
+PersistableQueuedMessage::operator=(const PersistableQueuedMessage& rhs)
+{
+    QueuedMessage::operator=(rhs);
+    m_enqHandle = rhs.m_enqHandle;
+    return *this;
+}
+
+const qpid::broker::EnqueueHandle&
+PersistableQueuedMessage::enqHandle() const
+{
+    return m_enqHandle;
+}
+
+qpid::broker::EnqueueHandle&
+PersistableQueuedMessage::enqHandle()
+{
+    return m_enqHandle;
+}
+
+}}} // tests::storePerftools::asyncPerf