in Dotnet core console app/AwsIOTMqttOverWebsockets/AwsIOTMqttOverWebsockets/Messaging/CloudConnector.cs [69:90]
public async Task SubscribeTo(string topic)
{
try
{
if (!isSubscribed)
{
mqttClient.ApplicationMessageReceived += MqttClient_ApplicationMessageReceived;
await mqttClient.SubscribeAsync(topic);
Logger.LogInfo($"Subscribed to: {topic}");
isSubscribed = true;
}
else
{
Logger.LogInfo($"Already subscribed to: {topic}");
}
}
catch (Exception ex)
{
Logger.LogError(ex.Message);
}
}