diff --git a/Source/MQTTnet/Server/MqttServer.cs b/Source/MQTTnet/Server/MqttServer.cs index 4c5ab62..a76e658 100644 --- a/Source/MQTTnet/Server/MqttServer.cs +++ b/Source/MQTTnet/Server/MqttServer.cs @@ -190,6 +190,8 @@ namespace MQTTnet.Server return _retainedMessagesManager?.ClearMessagesAsync(); } + public bool IsStarted => _cancellationTokenSource != null; + private Task OnHandleClient(IMqttChannelAdapter channelAdapter) { return _clientSessionsManager.HandleClientAsync(channelAdapter);