cpp/3.2.x/_message_id_8h_source.html

#ifndef MESSAGE_ID_H

#define MESSAGE_ID_H


#include <pulsar/defines.h>

#include <stdint.h>


#include <iosfwd>

#include <memory>

#include <string>

#include <vector>


namespace pulsar {


class MessageIdImpl;


class PULSAR_PUBLIC MessageId {

   public:

    MessageId& operator=(const MessageId&);

    MessageId();


    explicit MessageId(int32_t partition, int64_t ledgerId, int64_t entryId, int32_t batchIndex);


    static const MessageId& earliest();


    static const MessageId& latest();


    void serialize(std::string& result) const;


    const std::string& getTopicName() const;


    void setTopicName(const std::string& topicName);


    static MessageId deserialize(const std::string& serializedMessageId);


    // These functions compare the message order as stored in bookkeeper

    bool operator<(const MessageId& other) const;

    bool operator<=(const MessageId& other) const;

    bool operator>(const MessageId& other) const;

    bool operator>=(const MessageId& other) const;

    bool operator==(const MessageId& other) const;

    bool operator!=(const MessageId& other) const;


    int64_t ledgerId() const;

    int64_t entryId() const;

    int32_t batchIndex() const;

    int32_t partition() const;

    int32_t batchSize() const;


   private:

    friend class ConsumerImpl;

    friend class ReaderImpl;

    friend class Message;

    friend class MessageImpl;

    friend class Commands;

    friend class PartitionedProducerImpl;

    friend class MultiTopicsConsumerImpl;

    friend class UnAckedMessageTrackerEnabled;

    friend class BatchAcknowledgementTracker;

    friend class PulsarWrapper;

    friend class PulsarFriend;

    friend class NegativeAcksTracker;

    friend class MessageIdBuilder;

    friend class ChunkMessageIdImpl;


    void setTopicName(const std::shared_ptr<std::string>& topic);


    friend PULSAR_PUBLIC std::ostream& operator<<(std::ostream& s, const MessageId& messageId);


    typedef std::shared_ptr<MessageIdImpl> MessageIdImplPtr;

    MessageIdImplPtr impl_;


    explicit MessageId(const MessageIdImplPtr& impl);

};


typedef std::vector<MessageId> MessageIdList;

}  // namespace pulsar


#endif  // MESSAGE_ID_H