diff options
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp')
| -rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp index dd4de355b3..8ee858587b 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp +++ b/cpp/src/tests/storePerftools/asyncPerf/QueuedMessage.cpp @@ -79,4 +79,22 @@ QueuedMessage::enqHandle() return m_enqHandle; } +void +QueuedMessage::prepareEnqueue(qpid::broker::TxnHandle& th) +{ + m_queue->enqueue(th, *this); +} + +void +QueuedMessage::commitEnqueue() +{ + m_queue->process(m_msg); +} + +void +QueuedMessage::abortEnqueue() +{ + m_queue->enqueueAborted(m_msg); +} + }}} // namespace tests::storePerfTools |