Browse Source

Merge pull request #884 from chkr1011/feature-isconnected

Added check if the server is started or not.
release/3.x.x
Christian 4 years ago
committed by GitHub
parent
commit
aafc99f39e
No known key found for this signature in database GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 0 deletions
  1. +1
    -0
      Build/MQTTnet.nuspec
  2. +2
    -0
      Source/MQTTnet/Server/IMqttServer.cs
  3. +2
    -0
      Source/MQTTnet/Server/MqttServer.cs

+ 1
- 0
Build/MQTTnet.nuspec View File

@@ -26,6 +26,7 @@
* [Server] Added interceptor for unsubscriptions. * [Server] Added interceptor for unsubscriptions.
* [Server] Removed exceptions when user properties are set with MQTT protocol version 3.1 * [Server] Removed exceptions when user properties are set with MQTT protocol version 3.1
* [Server] Added custom session items to the client status. * [Server] Added custom session items to the client status.
* [Server] Added option to check whether the server is already started properly or not.
* [MQTTnet.AspNetCore] improved compatibility with AspNetCore 3.1 * [MQTTnet.AspNetCore] improved compatibility with AspNetCore 3.1
* [MQTTnet.Server] Added interceptor for unsubscriptions. * [MQTTnet.Server] Added interceptor for unsubscriptions.
</releaseNotes> </releaseNotes>


+ 2
- 0
Source/MQTTnet/Server/IMqttServer.cs View File

@@ -27,5 +27,7 @@ namespace MQTTnet.Server


Task StartAsync(IMqttServerOptions options); Task StartAsync(IMqttServerOptions options);
Task StopAsync(); Task StopAsync();

bool IsStarted { get; }
} }
} }

+ 2
- 0
Source/MQTTnet/Server/MqttServer.cs View File

@@ -190,6 +190,8 @@ namespace MQTTnet.Server
return _retainedMessagesManager?.ClearMessagesAsync(); return _retainedMessagesManager?.ClearMessagesAsync();
} }


public bool IsStarted => _cancellationTokenSource != null;

private Task OnHandleClient(IMqttChannelAdapter channelAdapter) private Task OnHandleClient(IMqttChannelAdapter channelAdapter)
{ {
return _clientSessionsManager.HandleClientConnectionAsync(channelAdapter); return _clientSessionsManager.HandleClientConnectionAsync(channelAdapter);


Loading…
Cancel
Save