amqp_properties.hpp

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
 
#pragma once
 
#include "amqp_value.hpp"
 
#include <azure/core/nullable.hpp>
 
#include <chrono>
#include <vector>
 
namespace Azure { namespace Core { namespace Amqp { namespace Models {
 
  struct MessageProperties final
  {
    MessageProperties() = default;
 
    ~MessageProperties() = default;
 
    MessageProperties(MessageProperties&& other) = default;
 
    MessageProperties& operator=(MessageProperties&& other) = default;
 
    MessageProperties(MessageProperties const& other) = default;
 
    MessageProperties& operator=(MessageProperties const& other) = default;
 
    Nullable<AmqpValue> MessageId;
 
    Nullable<std::vector<uint8_t>> UserId;
 
    Nullable<AmqpValue> To;
 
    Nullable<std::string> Subject;
 
    Nullable<AmqpValue> CorrelationId;
 
    Nullable<AmqpValue> ReplyTo;
 
    Nullable<std::string> ContentType;
 
    // cspell: ignore IANAHTTPPARAMS
    Nullable<std::string> ContentEncoding;
 
    Nullable<std::chrono::system_clock::time_point> AbsoluteExpiryTime;
 
    Nullable<std::chrono::system_clock::time_point> CreationTime;
 
    Nullable<std::string> GroupId;
 
    Nullable<uint32_t> GroupSequence;
 
    Nullable<std::string> ReplyToGroupId;
 
    bool operator==(MessageProperties const& that) const noexcept;
 
    bool ShouldSerialize() const noexcept;
 
    static std::vector<uint8_t> Serialize(MessageProperties const& properties);
 
    static MessageProperties Deserialize(uint8_t const* data, size_t size);
  };
 
  std::ostream& operator<<(std::ostream& stream, MessageProperties const& properties);
}}}} // namespace Azure::Core::Amqp::Models