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;
}
}