MQT TNet UseApplicationMessageReceivedHandler не запускается

Question

Я делаю ПО C, так что вот быстрый и грязный код. Я использую настольный клиент MQTT.fx для тестирования Pub / Sub на моем MQTT-сервере. Работает отлично. Я могу публиковать / подписываться на мои топи c. Я могу опубликовать sh с другого клиента mqtt, и я получаю сообщения. При использовании этого кода я ничего не получаю, когда публикую sh сообщения от MQTT.fx или любых других издателей. Я получу что-нибудь, если я опубликую sh с mqttClient (если вы раскомментируете строку). Я чешу голову ... Может кто-нибудь помочь? Спасибо.

class Program
{
    private static CancellationTokenSource cts = new CancellationTokenSource(); //TODO create token using the Timeout delay from config
    private static async Task Main(string[] args)
    {
        var factory = new MqttFactory();
        var mqttClient = factory.CreateMqttClient();
        var options = new MqttClientOptionsBuilder()
            .WithClientId("MyClientIDHere")
            .WithTcpServer("IPAddressHere", 1883)
            //.WithCredentials("Wbo", string.Empty)
            //.WithTls()
            .WithCleanSession()
            .Build();
        try
        {
            mqttClient.UseApplicationMessageReceivedHandler(async e =>
            {
                Console.WriteLine("### RECEIVED APPLICATION MESSAGE ###");
                Console.WriteLine($"+ Topic = {e.ApplicationMessage.Topic}");
                Console.WriteLine($"+ Payload = {Encoding.UTF8.GetString(e.ApplicationMessage.Payload)}");
                Console.WriteLine($"+ QoS = {e.ApplicationMessage.QualityOfServiceLevel}");
                Console.WriteLine($"+ Retain = {e.ApplicationMessage.Retain}");
                Console.WriteLine();
            });
            mqttClient.UseConnectedHandler(async e =>
            {
                Console.WriteLine("### CONNECTED WITH SERVER ###");

                // Subscribe to a topic
                await mqttClient.SubscribeAsync(new TopicFilterBuilder().WithTopic("MyClientIDHere/Device_2/Instance_1").Build());

                Console.WriteLine("### SUBSCRIBED ###");
            });
            await mqttClient.ConnectAsync(options, cts.Token);
           // UNCOMMENT AND YOU WILL RECEIVE A MESSAGE Task.Run(() => mqttClient.PublishAsync("MyClientIDHere/Device_2/Instance_1","met=Temperature~data=29"));

        }

        catch (OperationCanceledException)
        {
            Console.WriteLine("task cancelled");   
        }
        catch (Exception e)
        {
            Console.WriteLine(e);
        }

        Console.ReadKey();
    }
}