MessageBuilder.h

 
#ifndef MESSAGE_BUILDER_H
#define MESSAGE_BUILDER_H
 
#include <chrono>
#include <vector>
#include <pulsar/defines.h>
#include "Message.h"
 
namespace pulsar {
class PulsarWrapper;
 
class PULSAR_PUBLIC 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);
 
    MessageBuilder& setPartitionKey(const std::string& partitionKey);
 
    MessageBuilder& setOrderingKey(const std::string& orderingKey);
 
    MessageBuilder& setDeliverAfter(const std::chrono::milliseconds delay);
 
    MessageBuilder& setDeliverAt(uint64_t deliveryTimestamp);
 
    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
 
#endif