MessageId.h

 
#ifndef MESSAGE_ID_H
#define MESSAGE_ID_H
 
#include <iosfwd>
#include <stdint.h>
#include <memory>
#include <string>
#include <pulsar/defines.h>
 
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;
 
   private:
    friend class ConsumerImpl;
    friend class ReaderImpl;
    friend class Message;
    friend class MessageImpl;
    friend class Commands;
    friend class PartitionedProducerImpl;
    friend class PartitionedConsumerImpl;
    friend class MultiTopicsConsumerImpl;
    friend class UnAckedMessageTrackerEnabled;
    friend class BatchAcknowledgementTracker;
    friend class PulsarWrapper;
    friend class PulsarFriend;
    friend class NegativeAcksTracker;
 
    friend PULSAR_PUBLIC std::ostream& operator<<(std::ostream& s, const MessageId& messageId);
 
    typedef std::shared_ptr<MessageIdImpl> MessageIdImplPtr;
    MessageIdImplPtr impl_;
};
}  // namespace pulsar
 
#endif  // MESSAGE_ID_H