diff options
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h')
-rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.h | 12 |
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; |