diff options
Diffstat (limited to 'cpp/src/qpid/broker/MessageBuilder.h')
| -rw-r--r-- | cpp/src/qpid/broker/MessageBuilder.h | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/MessageBuilder.h b/cpp/src/qpid/broker/MessageBuilder.h index f4a9240b74..a533a4da6f 100644 --- a/cpp/src/qpid/broker/MessageBuilder.h +++ b/cpp/src/qpid/broker/MessageBuilder.h @@ -24,6 +24,7 @@ #include <qpid/QpidError.h> #include <qpid/broker/Exchange.h> #include <qpid/broker/Message.h> +#include <qpid/broker/MessageStore.h> #include <qpid/framing/AMQContentBody.h> #include <qpid/framing/AMQHeaderBody.h> #include <qpid/framing/BasicPublishBody.h> @@ -37,13 +38,16 @@ namespace qpid { virtual void complete(Message::shared_ptr&) = 0; virtual ~CompletionHandler(){} }; - MessageBuilder(CompletionHandler* _handler); + MessageBuilder(CompletionHandler* _handler, MessageStore* const store = 0, u_int64_t stagingThreshold = 0); void initialise(Message::shared_ptr& msg); void setHeader(qpid::framing::AMQHeaderBody::shared_ptr& header); void addContent(qpid::framing::AMQContentBody::shared_ptr& content); private: Message::shared_ptr message; CompletionHandler* handler; + MessageStore* const store; + const u_int64_t stagingThreshold; + bool staging; void route(); }; |