message_source.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"
 
#include <chrono>
#include <string>
 
struct SOURCE_INSTANCE_TAG;
 
namespace Azure { namespace Core { namespace Amqp { namespace Models { namespace _detail {
  class MessageSourceImpl;
}}}}} // namespace Azure::Core::Amqp::Models::_detail
 
namespace Azure { namespace Core { namespace Amqp { namespace Models { namespace _internal {
 
  struct MessageSourceOptions final
  {
    AmqpValue Address;
    Nullable<TerminusDurability> SourceTerminusDurability;
    Nullable<TerminusExpiryPolicy> SourceTerminusExpiryPolicy;
    Nullable<std::chrono::system_clock::time_point> Timeout;
    Nullable<bool> Dynamic;
    AmqpMap DynamicNodeProperties;
    Nullable<std::string> DistributionMode;
    AmqpMap Filter;
    AmqpValue DefaultOutcome;
    AmqpArray Outcomes;
    AmqpArray Capabilities;
  };
 
  class MessageSource final {
  public:
    MessageSource();
    ~MessageSource();
 
    // Create a described source from an AMQP Value - used in the OnLinkAttached.
    MessageSource(AmqpValue const& value);
 
    MessageSource(MessageSource const& that);
 
    MessageSource& operator=(MessageSource const& that);
 
    MessageSource(MessageSource&& other) noexcept;
 
    MessageSource& operator=(MessageSource&& other) noexcept;
 
    MessageSource(MessageSourceOptions const& options);
 
    /* Note: These constructors should NOT be marked as explicit, because we want to enable the
     * implicit construction of the MessageSource from a string - this allows callers to construct
     * Link, MessageSender, and MessageReceiver objects without forcing the creation of a
     * MessageSource object. */
 
    MessageSource(std::string const& address);
 
    MessageSource(char const* address);
 
    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;
 
    std::string GetDistributionMode() const;
 
    AmqpMap GetFilter() const;
 
    AmqpValue GetDefaultOutcome() const;
 
    AmqpArray GetOutcomes() const;
 
    AmqpArray GetCapabilities() const;
 
  private:
    std::unique_ptr<_detail::MessageSourceImpl> m_impl;
    // Declared as friend so it can access the private m_impl member.
    friend std::ostream& operator<<(std::ostream&, MessageSource const&);
  };
}}}}} // namespace Azure::Core::Amqp::Models::_internal