19#ifndef MESSAGE_BUILDER_H
20#define MESSAGE_BUILDER_H
22#include <pulsar/KeyValue.h>
23#include <pulsar/Message.h>
24#include <pulsar/defines.h>
37 typedef std::map<std::string, std::string> StringMap;
166 const char* data()
const;
167 std::size_t size()
const;
170 void checkMetadata();
171 static std::shared_ptr<MessageImpl> createMessageImpl();
172 Message::MessageImplPtr impl_;
174 friend class PulsarWrapper;
Definition MessageBuilder.h:33
MessageBuilder & setDeliverAt(uint64_t deliveryTimestamp)
MessageBuilder & setPartitionKey(const std::string &partitionKey)
MessageBuilder & setContent(const void *data, size_t size)
MessageBuilder & setAllocatedContent(void *data, size_t size)
MessageBuilder & setDeliverAfter(const std::chrono::milliseconds delay)
MessageBuilder & setEventTimestamp(uint64_t eventTimestamp)
MessageBuilder & setOrderingKey(const std::string &orderingKey)
MessageBuilder & setContent(const KeyValue &data)
MessageBuilder & setContent(std::string &&data)
MessageBuilder & setProperties(const StringMap &properties)
MessageBuilder & setSequenceId(int64_t sequenceId)
MessageBuilder & create()
MessageBuilder & setReplicationClusters(const std::vector< std::string > &clusters)
MessageBuilder & setProperty(const std::string &name, const std::string &value)
MessageBuilder & setContent(const std::string &data)
MessageBuilder & disableReplication(bool flag)
Definition Authentication.h:31