18 class DisconnectPacket;
20 class Mqtt5ClientOptions;
21 class NegotiatedSettings;
25 class SubscribePacket;
27 class UnsubscribePacket;
29 class Mqtt5ClientCore;
31 class Mqtt5to3AdapterOptions;
46 Default = AWS_MQTT5_COTABT_DEFAULT,
56 Manual = AWS_MQTT5_COTABT_MANUAL,
62 LRU = AWS_MQTT5_COTABT_LRU,
67 Disabled = AWS_MQTT5_COTABT_DISABLED,
84 Default = AWS_MQTT5_CITABT_DEFAULT,
89 Enabled = AWS_MQTT5_CITABT_ENABLED,
94 Disabled = AWS_MQTT5_CITABT_DISABLED,
315 std::function<void(const std::shared_ptr<Http::HttpRequest> &, int)>;
343 static std::shared_ptr<Mqtt5Client> NewMqtt5Client(
358 operator bool() const noexcept;
372 bool Start() const noexcept;
380 bool Stop() noexcept;
438 struct aws_mqtt5_client *GetUnderlyingHandle() const noexcept;
444 std::shared_ptr<Mqtt5ClientCore> m_client_core;
454 friend class Mqtt5ClientCore;
455 friend class Mqtt5to3AdapterOptions;
507 Mqtt5ClientOptions &WithTlsConnectionOptions(const Io::TlsConnectionOptions &tslOptions) noexcept;
517 const Crt::Http::HttpClientConnectionProxyOptions &proxyOptions) noexcept;
697 bool initializeRawOptions(aws_mqtt5_client_options &raw_options) const noexcept;
764 Io::ClientBootstrap *m_bootstrap;
770 Crt::Io::SocketOptions m_socketOptions;
776 Crt::
Optional<Crt::Io::TlsConnectionOptions> m_tlsConnectionOptions;
781 Crt::
Optional<Crt::Http::HttpClientConnectionProxyOptions> m_proxyOptions;
816 aws_mqtt5_client_topic_alias_options m_topicAliasingOptions;
822 uint32_t m_pingTimeoutMs;
828 uint32_t m_connackTimeoutMs;
834 uint32_t m_ackTimeoutSec;
838 aws_http_proxy_options m_httpProxyOptionsStorage;
839 aws_mqtt5_packet_connect_view m_packetConnectViewStorage;
std::shared_ptr< ConnAckPacket > connAckPacket
Definition: Mqtt5Client.h:219
Definition: Mqtt5Client.h:236
Definition: Mqtt5Client.h:248
#define AWS_CRT_CPP_API
Definition: Exports.h:36
std::function< void(const OnStoppedEventData &)> OnStoppedHandler
Definition: Mqtt5Client.h:288
Crt::Optional< uint16_t > m_outboundCacheMaxSize
Definition: Mqtt5Client.h:123
Definition: Mqtt5Packets.h:2037
Definition: Mqtt5Client.h:100
std::function< void(const OnConnectionFailureEventData &)> OnConnectionFailureHandler
Definition: Mqtt5Client.h:271
Definition: Mqtt5Packets.h:671
OnAttemptingConnectEventData()
Definition: Mqtt5Client.h:208
std::function< void(const std::shared_ptr< Http::HttpRequest > &, int)> OnWebSocketHandshakeInterceptComplete
Definition: Mqtt5Client.h:315
Definition: StringView.h:861
uint64_t incompleteOperationCount
Definition: Mqtt5Client.h:181
std::basic_string< char, std::char_traits< char >, StlAllocator< char >> String
Definition: Types.h:45
Crt::Optional< uint16_t > m_inboundCacheMaxSize
Definition: Mqtt5Client.h:141
aws_allocator Allocator
Definition: Allocator.h:14
Crt::Optional< InboundTopicAliasBehaviorType > m_inboundBehavior
Definition: Mqtt5Client.h:131
uint64_t unackedOperationSize
Definition: Mqtt5Client.h:199
OnConnectionFailureEventData()
Definition: Mqtt5Client.h:216
Definition: Mqtt5Packets.h:1559
std::shared_ptr< ConnAckPacket > connAckPacket
Definition: Mqtt5Client.h:229
aws_mqtt5_extended_validation_and_flow_control_options ClientExtendedValidationAndFlowControl
Definition: Mqtt5Types.h:200
std::function< void(int, std::shared_ptr< UnSubAckPacket >)> OnUnsubscribeCompletionHandler
Definition: Mqtt5Client.h:303
OutboundTopicAliasBehaviorType
Definition: Mqtt5Client.h:39
std::shared_ptr< PublishPacket > publishPacket
Definition: Mqtt5Client.h:259
aws_mqtt5_client_operation_queue_behavior_type ClientOperationQueueBehaviorType
Definition: Mqtt5Types.h:223
std::function< void(const OnConnectionSuccessEventData &)> OnConnectionSuccessHandler
Definition: Mqtt5Client.h:266
std::shared_ptr< DisconnectPacket > disconnectPacket
Definition: Mqtt5Client.h:241
Definition: Mqtt5Client.h:206
aws_mqtt5_client_session_behavior_type ClientSessionBehaviorType
Definition: Mqtt5Types.h:186
Definition: Mqtt5Packets.h:2243
AWS_CRT_CPP_API Allocator * ApiAllocator() noexcept
Definition: Allocator.cpp:24
Definition: Mqtt5Client.h:225
ExponentialBackoffJitterMode m_reconnectMode
Definition: Mqtt5Client.h:150
Definition: Mqtt5Client.h:175
Definition: Mqtt5Client.h:214
uint64_t incompleteOperationSize
Definition: Mqtt5Client.h:187
Definition: Mqtt5Client.h:144
uint64_t unackedOperationCount
Definition: Mqtt5Client.h:193
uint64_t m_maxReconnectDelayMs
Definition: Mqtt5Client.h:162
uint64_t m_minReconnectDelayMs
Definition: Mqtt5Client.h:156
OnDisconnectionEventData()
Definition: Mqtt5Client.h:238
Definition: Mqtt5Client.h:256
std::function< void(int, std::shared_ptr< PublishResult >)> OnPublishCompletionHandler
Definition: Mqtt5Client.h:293
OnConnectionSuccessEventData()
Definition: Mqtt5Client.h:227
AWS_CRT_CPP_API int LastError() noexcept
Definition: Api.cpp:425
PublishReceivedEventData()
Definition: Mqtt5Client.h:258
std::function< void(int, std::shared_ptr< SubAckPacket >)> OnSubscribeCompletionHandler
Definition: Mqtt5Client.h:298
aws_exponential_backoff_jitter_mode ExponentialBackoffJitterMode
Definition: Mqtt5Types.h:242
uint64_t m_minConnectedTimeToResetReconnectDelayMs
Definition: Mqtt5Client.h:169
OnStoppedEventData()
Definition: Mqtt5Client.h:250
std::function< void(const OnDisconnectionEventData &)> OnDisconnectionHandler
Definition: Mqtt5Client.h:276
Definition: Mqtt5Client.h:452
std::function< void(const OnAttemptingConnectEventData &)> OnAttemptingConnectHandler
Definition: Mqtt5Client.h:282
std::function< void(const PublishReceivedEventData &)> OnPublishReceivedHandler
Definition: Mqtt5Client.h:308
InboundTopicAliasBehaviorType
Definition: Mqtt5Client.h:77
Definition: Mqtt5Client.h:331
Crt::Optional< OutboundTopicAliasBehaviorType > m_outboundBehavior
Definition: Mqtt5Client.h:111
std::function< void(std::shared_ptr< Http::HttpRequest >, const OnWebSocketHandshakeInterceptComplete &)> OnWebSocketHandshakeIntercept
Definition: Mqtt5Client.h:324
std::shared_ptr< NegotiatedSettings > negotiatedSettings
Definition: Mqtt5Client.h:230
Definition: Mqtt5Packets.h:52
int errorCode
Definition: Mqtt5Client.h:240
Definition: MqttConnection.h:157
Definition: Allocator.h:10
int errorCode
Definition: Mqtt5Client.h:218