MessageBuilder.h

 
#ifndef MESSAGE_BUILDER_H
#define MESSAGE_BUILDER_H
 
#include <vector>
#include "Message.h"
 
#pragma GCC visibility push(default)
 
namespace pulsar {
class PulsarWrapper;
 
class MessageBuilder {
   public:
    MessageBuilder();
 
    typedef std::map<std::string, std::string> StringMap;
 
    Message build();
 
    MessageBuilder& setContent(const void* data, size_t size);
    MessageBuilder& setContent(const std::string& data);
 
    MessageBuilder& setAllocatedContent(void* data, size_t size);
 
    MessageBuilder& setProperty(const std::string& name, const std::string& value);
 
    MessageBuilder& setProperties(const StringMap& properties);
 
    /*
     * set partition key for the message routing
     * @param hash of this key is used to determine message's topic partition
     */
    MessageBuilder& setPartitionKey(const std::string& partitionKey);
 
    MessageBuilder& setEventTimestamp(uint64_t eventTimestamp);
 
    MessageBuilder& setSequenceId(int64_t sequenceId);
 
    MessageBuilder& setReplicationClusters(const std::vector<std::string>& clusters);
 
    MessageBuilder& disableReplication(bool flag);
 
    MessageBuilder& create();
 
   private:
    MessageBuilder(const MessageBuilder&);
    void checkMetadata();
    static std::shared_ptr<MessageImpl> createMessageImpl();
    Message::MessageImplPtr impl_;
 
    friend class PulsarWrapper;
};
}  // namespace pulsar
 
#pragma GCC visibility pop
 
#endif