Fix/mqtt disconnects docker linux (#286)

* Removed Awaiter from Mqtt PublishAsync to avaoid deadlocks.

* Extended Logging. Used synchronizationHelper.

---------

Signed-off-by: Matthias Dornaus <91789872+mdornaus@users.noreply.github.com>

Author: mdornaus

umatiGateway/Core/External/Opc.Ua.PubSub/Transport/MqttPubSubConnection.cs

@@ -41,6 +41,7 @@
 using System.Security.Authentication;
 using System.Security.Cryptography.X509Certificates;
 using System.Threading.Tasks;
+using umatiGateway.Core.Util;
 using DataSet = Opc.Ua.PubSub.PublishedData.DataSet;
 using JsonDataSetMessage = Opc.Ua.PubSub.Encoding.JsonDataSetMessage;
 using JsonNetworkMessage = Opc.Ua.PubSub.Encoding.JsonNetworkMessage;
@@ -335,17 +336,16 @@ public void StartWorker()
             {
                 foreach (MqttApplicationMessage message in this.messageQueue.GetConsumingEnumerable())
                 {
-                    if (m_publisherMqttClient != null && m_publisherMqttClient.IsConnected)
+                    Utils.LogInfo("Messages in Queue" + this.messageQueue.Count);
+                    try
                     {
-                        try
-                        {
-                            _ = this.m_publisherMqttClient.PublishAsync(message);
-                        }
-                        catch (Exception ex)
-                        {
-                            Utils.Trace(ex, "Exception on Sending Mqtt Message");
-                        }
+                        AsyncHelper.RunSync(() => m_publisherMqttClient!.PublishAsync(message));
                     }
+                    catch (Exception ex)
+                    {
+                        Utils.Trace(ex, "Exception on Sending Mqtt Message");
+                    }
+
                 }
             });
         }

umatiGateway/Core/Util/AsyncHelper.cs

@@ -13,7 +13,7 @@ public static class AsyncHelper
     {
         private static readonly TaskFactory _taskFactory = new
             TaskFactory(CancellationToken.None,
-                        TaskCreationOptions.None,
+                        TaskCreationOptions.DenyChildAttach,
                         TaskContinuationOptions.None,
                         TaskScheduler.Default);