diff --git a/backend/Api/MQTTReciever/MQTTReciever.cs b/backend/Api/MQTTReciever/MQTTReciever.cs
index bf01e52..162f504 100644
--- a/backend/Api/MQTTReciever/MQTTReciever.cs
+++ b/backend/Api/MQTTReciever/MQTTReciever.cs
@@ -52,9 +52,11 @@ namespace Api.MQTTReciever
                     string refernceId = mqttMessageReceive.device_id;
                     var device = _dbAccess.ReadDevice(refernceId);
 
+                    if (device == null) { return Task.CompletedTask; }
+
                     newLog.Temperature = mqttMessageReceive.temperature;
                     newLog.Date = DateTimeOffset.FromUnixTimeSeconds(mqttMessageReceive.timestamp).DateTime;
-                    newLog.TempHigh= device.TempHigh;
+                    newLog.TempHigh = device.TempHigh;
                     newLog.TempLow = device.TempLow;
 
                     _dbAccess.CreateLog(newLog, refernceId);
diff --git a/backend/Api/Program.cs b/backend/Api/Program.cs
index 7376c91..d3cdad5 100644
--- a/backend/Api/Program.cs
+++ b/backend/Api/Program.cs
@@ -10,19 +10,22 @@ class Program
     {
         var app = CreateWebHostBuilder(args).Build();
 
-
-        using (var scope = app.Services.CreateScope())
-        {
-            var services = scope.ServiceProvider;
-            var configuration = services.GetRequiredService<IConfiguration>();
-            var dbAccess = services.GetRequiredService<DbAccess>();
-
-            MQTTReciever mqtt = new MQTTReciever(configuration, dbAccess);
-            mqtt.Handle_Received_Application_Message();
-        }
-
         RunMigrations(app);
 
+        Task.Run(() =>
+        {
+            using (var scope = app.Services.CreateScope())
+            {
+                var services = scope.ServiceProvider;
+                var configuration = services.GetRequiredService<IConfiguration>();
+                var dbAccess = services.GetRequiredService<DbAccess>();
+
+                MQTTReciever mqtt = new MQTTReciever(configuration, dbAccess);
+                mqtt.Handle_Received_Application_Message().Wait();
+            }
+        });
+
+
         app.Run();
     }