diff --git a/DeviceStatus/Service/MessageHandler.cs b/DeviceStatus/Service/MessageHandler.cs index feaa5b7..0f8aa11 100644 --- a/DeviceStatus/Service/MessageHandler.cs +++ b/DeviceStatus/Service/MessageHandler.cs @@ -31,6 +31,8 @@ public class MessageHandler : IHostedService { _hubConnection = new HubConnectionBuilder().WithUrl(_configuration["Hub:DeviceStatus"]).Build(); _hubConnection.On("RequestLatestStatus", async () => await RequestLatestStatus()); + + await _hubConnection.StartAsync(cancellationToken); } var mqttFactory = new MqttFactory();