summaryrefslogtreecommitdiff
path: root/cpp/src/tests/storePerftools/asyncPerf/MessageDeque.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/MessageDeque.h')
-rw-r--r--cpp/src/tests/storePerftools/asyncPerf/MessageDeque.h6
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/MessageDeque.h b/cpp/src/tests/storePerftools/asyncPerf/MessageDeque.h
index 75f422779e..021015f3e0 100644
--- a/cpp/src/tests/storePerftools/asyncPerf/MessageDeque.h
+++ b/cpp/src/tests/storePerftools/asyncPerf/MessageDeque.h
@@ -46,10 +46,10 @@ public:
MessageDeque();
virtual ~MessageDeque();
uint32_t size();
- bool push(const QueuedMessage& added, QueuedMessage& removed);
- bool consume(QueuedMessage& msg);
+ bool push(boost::shared_ptr<QueuedMessage>& added);
+ bool consume(boost::shared_ptr<QueuedMessage>& msg);
private:
- std::deque<QueuedMessage> m_messages;
+ std::deque<boost::shared_ptr<QueuedMessage> > m_messages;
qpid::sys::Mutex m_msgMutex;
};