amqp_header.hpp

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
 
#pragma once
 
#include <azure/core/nullable.hpp>
 
#include <chrono>
#include <cstddef>
#include <cstdint>
#include <exception>
#include <stdexcept>
#include <vector>
 
namespace Azure { namespace Core { namespace Amqp { namespace Models {
  struct MessageHeader final
  {
    MessageHeader() = default;
    ~MessageHeader() = default;
 
    MessageHeader(MessageHeader&& other) = default;
 
    MessageHeader& operator=(MessageHeader&& other) = default;
 
    MessageHeader(MessageHeader const& other) = default;
 
    MessageHeader& operator=(MessageHeader const& other) = default;
 
    bool operator==(MessageHeader const& that) const noexcept;
 
    bool Durable{false};
 
    std::uint8_t Priority{4}; // Default priority is 4.
 
    Nullable<std::chrono::milliseconds> TimeToLive;
 
    bool IsFirstAcquirer{false};
 
    std::uint32_t DeliveryCount{0};
 
    bool ShouldSerialize() const noexcept;
 
    static size_t GetSerializedSize(MessageHeader const& messageHeader);
 
    static std::vector<uint8_t> Serialize(MessageHeader const& messageHeader);
 
    static MessageHeader Deserialize(std::uint8_t const* data, size_t size);
  };
 
  std::ostream& operator<<(std::ostream&, MessageHeader const&);
 
}}}} // namespace Azure::Core::Amqp::Models