summaryrefslogtreecommitdiff
path: root/cpp/lib/broker/MessageBuilder.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/broker/MessageBuilder.h')
-rw-r--r--cpp/lib/broker/MessageBuilder.h11
1 files changed, 4 insertions, 7 deletions
diff --git a/cpp/lib/broker/MessageBuilder.h b/cpp/lib/broker/MessageBuilder.h
index 5b8516be42..f0b90a86cd 100644
--- a/cpp/lib/broker/MessageBuilder.h
+++ b/cpp/lib/broker/MessageBuilder.h
@@ -29,22 +29,19 @@
#include <AMQContentBody.h>
#include <AMQHeaderBody.h>
#include <BasicPublishBody.h>
+#include "CompletionHandler.h"
namespace qpid {
namespace broker {
class MessageBuilder{
public:
- class CompletionHandler{
- public:
- virtual void complete(Message::shared_ptr&) = 0;
- virtual ~CompletionHandler(){}
- };
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);
+ void setHeader(framing::AMQHeaderBody::shared_ptr& header);
+ void addContent(framing::AMQContentBody::shared_ptr& content);
+ Message::shared_ptr getMessage() { return message; }
private:
Message::shared_ptr message;
CompletionHandler* handler;