in dotnet-core/AWS.IoT.FleetProvisioning/IoTClient/ProvisioningClient.cs [150:163]
private void ClientOnMqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
{
_logger.LogTrace($"OnMqttMsgPublishReceived on topic: '{e.Topic}' with QoS level '{e.QosLevel}'");
var message = Encoding.UTF8.GetString(e.Message);
_logger.LogTrace($"{nameof(message)}: {message}");
_messageCallback?.Invoke(message);
if (_subscribeCallbackDictionary.ContainsKey(e.Topic))
{
_subscribeCallbackDictionary[e.Topic].Invoke(message);
}
}