summaryrefslogtreecommitdiff
path: root/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h')
-rw-r--r--cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h12
1 files changed, 12 insertions, 0 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h
index 29e7f792cd..896c53ab5b 100644
--- a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h
+++ b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h
@@ -28,6 +28,13 @@
#include <boost/intrusive_ptr.hpp>
+namespace qpid {
+namespace broker {
+
+class TxnHandle;
+
+}}
+
namespace tests {
namespace storePerftools {
namespace asyncPerf {
@@ -48,6 +55,11 @@ public:
const qpid::broker::EnqueueHandle& enqHandle() const;
qpid::broker::EnqueueHandle& enqHandle();
+ // -- Transaction handling ---
+ void prepareEnqueue(qpid::broker::TxnHandle& th);
+ void commitEnqueue();
+ void abortEnqueue();
+
private:
SimplePersistableQueue* m_queue;
boost::intrusive_ptr<SimplePersistableMessage> m_msg;