message_target.hpp

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
 
#pragma once
 
#include "azure/core/amqp/models/amqp_header.hpp"
#include "azure/core/amqp/models/amqp_properties.hpp"
#include "azure/core/amqp/models/amqp_value.hpp"
 
namespace Azure { namespace Core { namespace Amqp { namespace Models { namespace _detail {
  class MessageTargetImpl;
}}}}} // namespace Azure::Core::Amqp::Models::_detail
 
namespace Azure { namespace Core { namespace Amqp { namespace Models { namespace _internal {
 
  struct MessageTargetOptions final
  {
    AmqpValue Address;
    Nullable<TerminusDurability> TerminusDurabilityValue;
    Nullable<TerminusExpiryPolicy> TerminusExpiryPolicyValue;
    Nullable<std::chrono::system_clock::time_point> Timeout;
    Nullable<bool> Dynamic;
    AmqpMap DynamicNodeProperties;
    AmqpArray Capabilities;
  };
 
  class MessageTarget final {
  public:
    MessageTarget();
    ~MessageTarget();
 
    MessageTarget(MessageTarget const& that);
 
    MessageTarget& operator=(MessageTarget const& that);
 
    MessageTarget(MessageTarget&&) noexcept;
 
    MessageTarget& operator=(MessageTarget&&) noexcept;
 
    /* Note: These constructors should NOT be marked as explicit, because we want to enable the
     * implicit construction of the MessageTarget from a string - this allows callers to construct
     * Link, MessageSender, and MessageReceiver objects without forcing the creation of a
     * MessageSource object. */
 
    MessageTarget(std::string const& address);
 
    MessageTarget(char const* address);
 
    MessageTarget(MessageTargetOptions const& options);
 
    MessageTarget(Models::AmqpValue const& value);
 
    AmqpValue AsAmqpValue() const;
 
    AmqpValue GetAddress() const;
 
    TerminusDurability GetTerminusDurability() const;
 
    TerminusExpiryPolicy GetExpiryPolicy() const;
 
    std::chrono::system_clock::time_point GetTimeout() const;
 
    bool GetDynamic() const;
 
    AmqpMap GetDynamicNodeProperties() const;
 
    AmqpArray GetCapabilities() const;
 
  private:
    std::unique_ptr<_detail::MessageTargetImpl> m_impl;
 
    // Declared as friend so it can use the TARGET_INSTANCE_TAG* overload.
    friend std::ostream& operator<<(std::ostream&, MessageTarget const&);
  };
 
}}}}} // namespace Azure::Core::Amqp::Models::_internal