From ce534baa750bf5f4a89d38f173c13f65d9253660 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Wed, 4 Jul 2018 22:20:24 +0200 Subject: [PATCH] Move the connection check interval of the ManagedClient to the options. --- .../IManagedMqttClientOptions.cs | 2 ++ Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs | 2 +- .../ManagedMqttClientOptions.cs | 2 ++ 3 files changed, 5 insertions(+), 1 deletion(-) diff --git a/Source/MQTTnet.Extensions.ManagedClient/IManagedMqttClientOptions.cs b/Source/MQTTnet.Extensions.ManagedClient/IManagedMqttClientOptions.cs index 77736c44..8d48babd 100644 --- a/Source/MQTTnet.Extensions.ManagedClient/IManagedMqttClientOptions.cs +++ b/Source/MQTTnet.Extensions.ManagedClient/IManagedMqttClientOptions.cs @@ -9,6 +9,8 @@ namespace MQTTnet.Extensions.ManagedClient TimeSpan AutoReconnectDelay { get; } + TimeSpan ConnectionCheckInterval { get; } + IManagedMqttClientStorage Storage { get; } } } \ No newline at end of file diff --git a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs index bcd98ae7..2eabce33 100644 --- a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs +++ b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs @@ -206,7 +206,7 @@ namespace MQTTnet.Extensions.ManagedClient if (connectionState == ReconnectionResult.StillConnected) { - await Task.Delay(TimeSpan.FromSeconds(1), cancellationToken).ConfigureAwait(false); + await Task.Delay(_options.ConnectionCheckInterval, cancellationToken).ConfigureAwait(false); } } catch (OperationCanceledException) diff --git a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClientOptions.cs b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClientOptions.cs index e07e2d68..cecf2274 100644 --- a/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClientOptions.cs +++ b/Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClientOptions.cs @@ -9,6 +9,8 @@ namespace MQTTnet.Extensions.ManagedClient public TimeSpan AutoReconnectDelay { get; set; } = TimeSpan.FromSeconds(5); + public TimeSpan ConnectionCheckInterval { get; set; } = TimeSpan.FromSeconds(1); + public IManagedMqttClientStorage Storage { get; set; } } }