Message.h

#ifndef MESSAGE_HPP_
#define MESSAGE_HPP_
 
#include <pulsar/EncryptionContext.h>
#include <pulsar/defines.h>
 
#include <map>
#include <memory>
#include <optional>
#include <string>
 
#include "KeyValue.h"
#include "MessageId.h"
 
namespace pulsar {
namespace proto {
class CommandMessage;
class BrokerEntryMetadata;
class MessageMetadata;
class SingleMessageMetadata;
}  // namespace proto
 
class SharedBuffer;
class MessageBuilder;
class MessageImpl;
class PulsarWrapper;
 
class PULSAR_PUBLIC Message {
   public:
    typedef std::map<std::string, std::string> StringMap;
 
    Message();

    const StringMap& getProperties() const;

    bool hasProperty(const std::string& name) const;

    const std::string& getProperty(const std::string& name) const;

    const void* getData() const;

    std::size_t getLength() const;

#if defined(_MSC_VER) && !defined(NDEBUG)
    const std::string& getDataAsString() const;
#else
    std::string getDataAsString() const;
#endif

    KeyValue getKeyValueData() const;

    const MessageId& getMessageId() const;

    void setMessageId(const MessageId& messageId) const;

    int64_t getIndex() const;

    const std::string& getPartitionKey() const;

    bool hasPartitionKey() const;

    const std::string& getOrderingKey() const;

    bool hasOrderingKey() const;

    uint64_t getPublishTimestamp() const;

    uint64_t getEventTimestamp() const;

    const std::string& getTopicName() const;

    int getRedeliveryCount() const;

    bool hasSchemaVersion() const;

    int64_t getLongSchemaVersion() const;

    const std::string& getSchemaVersion() const;

    void setSchemaVersion(const std::string& schemaVersion);

    const std::string& getProducerName() const noexcept;

    std::optional<const EncryptionContext*> getEncryptionContext() const;
 
    bool operator==(const Message& msg) const;
 
   protected:
    typedef std::shared_ptr<MessageImpl> MessageImplPtr;
    MessageImplPtr impl_;
 
    Message(MessageImplPtr& impl);
    Message(const MessageId& messageId, proto::BrokerEntryMetadata& brokerEntryMetadata,
            proto::MessageMetadata& metadata, SharedBuffer& payload);
    Message(const MessageId& messageId, proto::BrokerEntryMetadata& brokerEntryMetadata,
            proto::MessageMetadata& metadata, SharedBuffer& payload,
            proto::SingleMessageMetadata& singleMetadata, const std::shared_ptr<std::string>& topicName);
    friend class PartitionedProducerImpl;
    friend class MultiTopicsConsumerImpl;
    friend class MessageBuilder;
    friend class ConsumerImpl;
    friend class ProducerImpl;
    friend class Commands;
    friend class BatchMessageContainerBase;
    friend class BatchAcknowledgementTracker;
    friend class PulsarWrapper;
    friend class MessageBatch;
    friend struct OpSendMsg;
 
    friend PULSAR_PUBLIC std::ostream& operator<<(std::ostream& s, const StringMap& map);
    friend PULSAR_PUBLIC std::ostream& operator<<(std::ostream& s, const Message& msg);
    friend class PulsarFriend;
};
}  // namespace pulsar
 
#endif /* MESSAGE_HPP_ */