MqttClient.h

Go to the documentation of this file.

#pragma once
#include <aws/crt/Exports.h>
#include <aws/crt/StlAllocator.h>
#include <aws/crt/Types.h>
#include <aws/crt/http/HttpConnection.h>
#include <aws/crt/io/SocketOptions.h>
#include <aws/crt/io/TlsOptions.h>
#include <aws/crt/mqtt/MqttConnection.h>
 
#include <aws/mqtt/client.h>
#include <aws/mqtt/v5/mqtt5_client.h>
 
#include <atomic>
#include <functional>
#include <memory>
 
namespace Aws
{
    namespace Crt
    {
        namespace Io
        {
            class ClientBootstrap;
        }
 
        namespace Http
        {
            class HttpRequest;
        }
 
        namespace Mqtt5
        {
            class Mqtt5ClientCore;
        }
 
        namespace Mqtt
        {
            class AWS_CRT_CPP_API MqttClient final
            {
              public:
                MqttClient(Io::ClientBootstrap &bootstrap, Allocator *allocator = ApiAllocator()) noexcept;
 
                MqttClient(Allocator *allocator = ApiAllocator()) noexcept;
 
                ~MqttClient();
                MqttClient(const MqttClient &) = delete;
                MqttClient(MqttClient &&) noexcept;
                MqttClient &operator=(const MqttClient &) = delete;
                MqttClient &operator=(MqttClient &&) noexcept;
 
                operator bool() const noexcept;
 
                int LastError() const noexcept;
 
                std::shared_ptr<MqttConnection> NewConnection(
                    const char *hostName,
                    uint32_t port,
                    const Io::SocketOptions &socketOptions,
                    const Crt::Io::TlsContext &tlsContext,
                    bool useWebsocket = false,
                    bool enableMetrics = true) noexcept;
 
                std::shared_ptr<MqttConnection> NewConnection(
                    const char *hostName,
                    uint32_t port,
                    const Io::SocketOptions &socketOptions,
                    bool useWebsocket = false,
                    bool enableMetrics = true) noexcept;
 
              private:
                aws_mqtt_client *m_client;
            };
        } // namespace Mqtt
    } // namespace Crt
} // namespace Aws