api/rocketmq/MQMessageExt.h

#pragma once

#include "MQMessage.h"
#include <chrono>

ROCKETMQ_NAMESPACE_BEGIN

class MessageAccessor;

class MQMessageExt : public MQMessage {
public:
  MQMessageExt();

  MQMessageExt(const MQMessageExt& other);

  MQMessageExt& operator=(const MQMessageExt& other);

  int32_t getQueueId() const;

  /**
   * @return Milli-seconds since epoch in perspective of system_clock.
   */
  int64_t getBornTimestamp() const;

  std::chrono::system_clock::time_point bornTimestamp() const;

  std::chrono::system_clock::time_point storeTimestamp() const;
  int64_t getStoreTimestamp() const;

  std::string getStoreHost() const;

  int64_t getQueueOffset() const;

  int32_t getDeliveryAttempt() const;

  const std::string& receiptHandle() const;

  bool operator==(const MQMessageExt& other);

  friend class MessageAccessor;
};

ROCKETMQ_NAMESPACE_END