summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/RecoveredEnqueue.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/RecoveredEnqueue.h')
-rw-r--r--cpp/src/qpid/broker/RecoveredEnqueue.h4
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/RecoveredEnqueue.h b/cpp/src/qpid/broker/RecoveredEnqueue.h
index 9ada62e62b..25b55e3e0c 100644
--- a/cpp/src/qpid/broker/RecoveredEnqueue.h
+++ b/cpp/src/qpid/broker/RecoveredEnqueue.h
@@ -34,10 +34,10 @@ namespace qpid {
namespace broker {
class RecoveredEnqueue : public TxOp{
Queue::shared_ptr queue;
- Message::shared_ptr msg;
+ intrusive_ptr<Message> msg;
public:
- RecoveredEnqueue(Queue::shared_ptr queue, Message::shared_ptr msg);
+ RecoveredEnqueue(Queue::shared_ptr queue, intrusive_ptr<Message> msg);
virtual bool prepare(TransactionContext* ctxt) throw();
virtual void commit() throw();
virtual void rollback() throw();