summaryrefslogtreecommitdiff
path: root/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.h')
-rw-r--r--cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.h3
1 files changed, 2 insertions, 1 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.h b/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.h
index 1366c7772b..3bc0972ede 100644
--- a/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.h
+++ b/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.h
@@ -31,6 +31,7 @@
#include "qpid/broker/QueueHandle.h"
#include "qpid/sys/Monitor.h"
+#include <boost/intrusive_ptr.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
@@ -75,7 +76,7 @@ public:
void asyncDestroy(const bool deleteQueue);
// --- Methods in msg handling path from qpid::Queue ---
- void deliver(boost::shared_ptr<SimplePersistableMessage> msg);
+ void deliver(boost::intrusive_ptr<SimplePersistableMessage> msg);
bool dispatch(); // similar to qpid::broker::Queue::distpatch(Consumer&) but without Consumer param
bool enqueue(SimpleTransactionContext* ctxt,
QueuedMessage& qm);