WIP - transactional consume path completed, still some testing to be done.

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1353703 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 1 deletions

diff --git a/cpp/src/tests/storePerftools/asyncPerf/SimpleQueue.h b/cpp/src/tests/storePerftools/asyncPerf/SimpleQueue.h
index bc9dda0d98..59e12b5c93 100644
--- a/cpp/src/tests/storePerftools/asyncPerf/SimpleQueue.h
+++ b/cpp/src/tests/storePerftools/asyncPerf/SimpleQueue.h
@@ -50,6 +50,7 @@ namespace tests {
 namespace storePerftools {
 namespace asyncPerf {
 
+class MessageConsumer;
 class Messages;
 class SimpleMessage;
 class QueueAsyncContext;
@@ -76,9 +77,11 @@ public:
 
     // --- Methods in msg handling path from qpid::Queue ---
     void deliver(boost::intrusive_ptr<SimpleMessage> msg);
-    bool dispatch(); // similar to qpid::broker::Queue::distpatch(Consumer&) but without Consumer param
+    bool dispatch(MessageConsumer& mc);
+    bool enqueue(QueuedMessage& qm);
     bool enqueue(qpid::broker::TxnHandle& th,
                  QueuedMessage& qm);
+    bool dequeue(QueuedMessage& qm);
     bool dequeue(qpid::broker::TxnHandle& th,
                  QueuedMessage& qm);
     void process(boost::intrusive_ptr<SimpleMessage> msg);