28 class AWS_CRT_CPP_API Mqtt5ClientCore final :
public std::enable_shared_from_this<Mqtt5ClientCore>
30 friend class Mqtt5Client;
31 friend class Mqtt::MqttConnection;
41 static std::shared_ptr<Mqtt5ClientCore> NewMqtt5ClientCore(
42 const Mqtt5ClientOptions &options,
51 std::shared_ptr<Mqtt5ClientCore> getptr() {
return shared_from_this(); }
56 operator bool() const noexcept;
72 std::shared_ptr<PublishPacket> publishOptions,
84 std::shared_ptr<SubscribePacket> subscribeOptions,
96 std::shared_ptr<UnsubscribePacket> unsubscribeOptions,
108 void Close() noexcept;
112 struct aws_mqtt5_client *GetUnderlyingHandle() const noexcept {
return m_client; }
125 std::shared_ptr<Crt::Mqtt::MqttConnection> NewConnection(
126 const Mqtt5::Mqtt5to3AdapterOptions *options) noexcept;
129 static
void s_publishCompletionCallback(
130 enum aws_mqtt5_packet_type packet_type,
135 static
void s_subscribeCompletionCallback(
136 const struct aws_mqtt5_packet_suback_view *puback,
140 static
void s_unsubscribeCompletionCallback(
141 const struct aws_mqtt5_packet_unsuback_view *puback,
145 static
void s_lifeCycleEventCallback(const aws_mqtt5_client_lifecycle_event *event);
147 static
void s_publishReceivedCallback(const aws_mqtt5_packet_publish_view *publish,
void *user_data);
149 static
void s_onWebsocketHandshake(
150 aws_http_message *rawRequest,
152 aws_mqtt5_transform_websocket_handshake_complete_fn *complete_fn,
155 static
void s_clientTerminationCompletion(
void *complete_ctx);
193 std::shared_ptr<Mqtt5ClientCore> m_selfReference;
212 std::recursive_mutex m_callback_lock;
214 aws_mqtt5_client *m_client;
221 class Mqtt5to3AdapterOptions
223 friend class Mqtt5ClientOptions;
224 friend class Mqtt5ClientCore;
225 friend class Mqtt::MqttConnection;
229 Mqtt5to3AdapterOptions();
236 static ScopedResource<Mqtt5to3AdapterOptions> NewMqtt5to3AdapterOptions(
237 const Mqtt5ClientOptions &options) noexcept;
240 Mqtt::MqttConnectionOptions m_mqtt3Options;
256 Crt::Optional<Crt::Http::HttpClientConnectionProxyOptions> m_proxyOptions;
#define AWS_CRT_CPP_API
Definition: Exports.h:36
std::function< void(const OnStoppedEventData &)> OnStoppedHandler
Definition: Mqtt5Client.h:288
std::function< void(const OnConnectionFailureEventData &)> OnConnectionFailureHandler
Definition: Mqtt5Client.h:271
Definition: StringView.h:861
std::basic_string< char, std::char_traits< char >, StlAllocator< char >> String
Definition: Types.h:45
aws_allocator Allocator
Definition: Allocator.h:14
std::function< void(std::shared_ptr< Http::HttpRequest > req, const OnWebSocketHandshakeInterceptComplete &onComplete)> OnWebSocketHandshakeIntercept
Definition: MqttConnection.h:146
std::function< void(int, std::shared_ptr< UnSubAckPacket >)> OnUnsubscribeCompletionHandler
Definition: Mqtt5Client.h:303
std::function< void(const OnConnectionSuccessEventData &)> OnConnectionSuccessHandler
Definition: Mqtt5Client.h:266
AWS_CRT_CPP_API Allocator * ApiAllocator() noexcept
Definition: Allocator.cpp:24
std::function< void(int, std::shared_ptr< PublishResult >)> OnPublishCompletionHandler
Definition: Mqtt5Client.h:293
AWS_CRT_CPP_API int LastError() noexcept
Definition: Api.cpp:425
std::function< void(int, std::shared_ptr< SubAckPacket >)> OnSubscribeCompletionHandler
Definition: Mqtt5Client.h:298
std::function< void(const OnDisconnectionEventData &)> OnDisconnectionHandler
Definition: Mqtt5Client.h:276
std::unique_ptr< T, std::function< void(T *)>> ScopedResource
Definition: Types.h:163
std::function< void(const OnAttemptingConnectEventData &)> OnAttemptingConnectHandler
Definition: Mqtt5Client.h:282
std::function< void(const PublishReceivedEventData &)> OnPublishReceivedHandler
Definition: Mqtt5Client.h:308
std::function< void(std::shared_ptr< Http::HttpRequest >, const OnWebSocketHandshakeInterceptComplete &)> OnWebSocketHandshakeIntercept
Definition: Mqtt5Client.h:324
Definition: Allocator.h:10