summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/RecoveredDequeue.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/RecoveredDequeue.h')
-rw-r--r--cpp/src/qpid/broker/RecoveredDequeue.h13
1 files changed, 8 insertions, 5 deletions
diff --git a/cpp/src/qpid/broker/RecoveredDequeue.h b/cpp/src/qpid/broker/RecoveredDequeue.h
index 82668adb67..276e1f4c5c 100644
--- a/cpp/src/qpid/broker/RecoveredDequeue.h
+++ b/cpp/src/qpid/broker/RecoveredDequeue.h
@@ -21,23 +21,26 @@
#ifndef _RecoveredDequeue_
#define _RecoveredDequeue_
-#include <algorithm>
-#include <functional>
-#include <list>
#include "Deliverable.h"
#include "Message.h"
#include "MessageStore.h"
#include "Queue.h"
#include "TxOp.h"
+#include <boost/intrusive_ptr.hpp>
+
+#include <algorithm>
+#include <functional>
+#include <list>
+
namespace qpid {
namespace broker {
class RecoveredDequeue : public TxOp{
Queue::shared_ptr queue;
- intrusive_ptr<Message> msg;
+ boost::intrusive_ptr<Message> msg;
public:
- RecoveredDequeue(Queue::shared_ptr queue, intrusive_ptr<Message> msg);
+ RecoveredDequeue(Queue::shared_ptr queue, boost::intrusive_ptr<Message> msg);
virtual bool prepare(TransactionContext* ctxt) throw();
virtual void commit() throw();
virtual void rollback() throw();