summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/TxPublish.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/TxPublish.h')
-rw-r--r--cpp/src/qpid/broker/TxPublish.h12
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/qpid/broker/TxPublish.h b/cpp/src/qpid/broker/TxPublish.h
index 2e3268010a..b4323864bc 100644
--- a/cpp/src/qpid/broker/TxPublish.h
+++ b/cpp/src/qpid/broker/TxPublish.h
@@ -45,24 +45,24 @@ namespace qpid {
class TxPublish : public TxOp, public Deliverable{
class Prepare{
TransactionContext* ctxt;
- Message::shared_ptr& msg;
+ intrusive_ptr<Message>& msg;
public:
- Prepare(TransactionContext* ctxt, Message::shared_ptr& msg);
+ Prepare(TransactionContext* ctxt, intrusive_ptr<Message>& msg);
void operator()(Queue::shared_ptr& queue);
};
class Commit{
- Message::shared_ptr& msg;
+ intrusive_ptr<Message>& msg;
public:
- Commit(Message::shared_ptr& msg);
+ Commit(intrusive_ptr<Message>& msg);
void operator()(Queue::shared_ptr& queue);
};
- Message::shared_ptr msg;
+ intrusive_ptr<Message> msg;
std::list<Queue::shared_ptr> queues;
public:
- TxPublish(Message::shared_ptr msg);
+ TxPublish(intrusive_ptr<Message> msg);
virtual bool prepare(TransactionContext* ctxt) throw();
virtual void commit() throw();
virtual void rollback() throw();