diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/DeliverableMessage.h')
-rw-r--r-- | qpid/cpp/src/qpid/broker/DeliverableMessage.h | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/qpid/cpp/src/qpid/broker/DeliverableMessage.h b/qpid/cpp/src/qpid/broker/DeliverableMessage.h index c8d21001eb..d6d6bf5265 100644 --- a/qpid/cpp/src/qpid/broker/DeliverableMessage.h +++ b/qpid/cpp/src/qpid/broker/DeliverableMessage.h @@ -25,14 +25,15 @@ #include "qpid/broker/Deliverable.h" #include "qpid/broker/Message.h" -#include <boost/intrusive_ptr.hpp> - namespace qpid { namespace broker { - class QPID_BROKER_CLASS_EXTERN DeliverableMessage : public Deliverable{ - boost::intrusive_ptr<Message> msg; + class TxBuffer; + class QPID_BROKER_CLASS_EXTERN DeliverableMessage : public Deliverable + { + Message msg; + TxBuffer* txn; public: - QPID_BROKER_EXTERN DeliverableMessage(const boost::intrusive_ptr<Message>& msg); + QPID_BROKER_EXTERN DeliverableMessage(const Message& msg, TxBuffer* txn); QPID_BROKER_EXTERN virtual void deliverTo(const boost::shared_ptr<Queue>& queue); QPID_BROKER_EXTERN Message& getMessage(); QPID_BROKER_EXTERN uint64_t contentSize(); |