25 #include <boost/shared_ptr.hpp> 26 #include "BatchMessageId.h" 28 #pragma GCC visibility push(default) 33 class MessageMetadata;
34 class SingleMessageMetadata;
44 typedef std::map<std::string, std::string> StringMap;
71 const std::string&
getProperty(
const std::string& name)
const;
110 bool hasPartitionKey()
const;
118 typedef boost::shared_ptr<MessageImpl> MessageImplPtr;
119 MessageImplPtr impl_;
122 Message(
const proto::CommandMessage& msg, proto::MessageMetadata& data, SharedBuffer& payload);
124 Message(
const BatchMessageId& messageID, proto::MessageMetadata& metadata, SharedBuffer& payload, proto::SingleMessageMetadata& singleMetadata);
125 friend class PartitionedProducerImpl;
126 friend class PartitionedConsumerImpl;
128 friend class ConsumerImpl;
129 friend class ProducerImpl;
130 friend class Commands;
131 friend class BatchMessageContainer;
132 friend class BatchAcknowledgementTracker;
133 friend class PulsarWrapper;
135 friend std::ostream& operator<<(std::ostream& s,
const StringMap& map);
136 friend std::ostream& operator<<(std::ostream& s,
const Message& msg);
141 #pragma GCC visibility pop Definition: MessageBuilder.h:30
Definition: Authentication.h:31
const std::string & getProperty(const std::string &name) const
std::size_t getLength() const
const StringMap & getProperties() const
bool hasProperty(const std::string &name) const
Definition: BatchMessageId.h:26
const MessageId & getMessageId() const
const void * getData() const
std::string getDataAsString() const
Definition: MessageId.h:33
uint64_t getPublishTimestamp() const
const std::string & getPartitionKey() const