summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MessageBuilder.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/MessageBuilder.h')
-rw-r--r--cpp/src/qpid/broker/MessageBuilder.h6
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/MessageBuilder.h b/cpp/src/qpid/broker/MessageBuilder.h
index 134f93b68f..c7ed2abc04 100644
--- a/cpp/src/qpid/broker/MessageBuilder.h
+++ b/cpp/src/qpid/broker/MessageBuilder.h
@@ -21,9 +21,9 @@
#ifndef _MessageBuilder_
#define _MessageBuilder_
-#include "boost/shared_ptr.hpp"
#include "qpid/framing/FrameHandler.h"
#include "qpid/framing/SequenceNumber.h"
+#include "qpid/RefCounted.h"
namespace qpid {
namespace broker {
@@ -34,13 +34,13 @@ namespace qpid {
public:
MessageBuilder(MessageStore* const store = 0, uint64_t stagingThreshold = 0);
void handle(framing::AMQFrame& frame);
- boost::shared_ptr<Message> getMessage() { return message; }
+ intrusive_ptr<Message> getMessage() { return message; }
void start(const framing::SequenceNumber& id);
void end();
private:
enum State {DORMANT, METHOD, HEADER, CONTENT};
State state;
- boost::shared_ptr<Message> message;
+ intrusive_ptr<Message> message;
MessageStore* const store;
const uint64_t stagingThreshold;
bool staging;