public async Task ConnectToAwsIoT()

in Dotnet core console app/AwsIOTMqttOverWebsockets/AwsIOTMqttOverWebsockets/Messaging/CloudConnector.cs [25:54]


        public async Task ConnectToAwsIoT()
        {
            try
            {
                AwsMqttConnection awsMqttConnection = new AwsMqttConnection
                {
                    Host = cloudConnectionConfig.Host,
                    Region = cloudConnectionConfig.Region,
                    AccessKey = cloudConnectionConfig.AccessKey,
                    SecretKey = cloudConnectionConfig.SecretKey
                };

                string signedRequestUrl = awsMqttConnection.SignRequestUrl();

                var factory = new MqttFactory();
                mqttClient = factory.CreateMqttClient();

                mqttClientOptions = new MqttClientOptionsBuilder()
                        .WithWebSocketServer(signedRequestUrl)
                        .Build();

                await mqttClient.ConnectAsync(mqttClientOptions);
                Logger.LogInfo("Connected successfully .....");
            }
            catch (Exception ex)
            {
                Logger.LogError(ex.Message);
                throw;
            }
        }