summaryrefslogtreecommitdiff
path: root/cpp/src/tests/storePerftools/asyncPerf/SimpleQueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/SimpleQueue.h')
-rw-r--r--cpp/src/tests/storePerftools/asyncPerf/SimpleQueue.h5
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);