diff --git a/Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs b/Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs index 8afb7acd..f1a209b4 100644 --- a/Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs +++ b/Source/MQTTnet/Server/MqttClientKeepAliveMonitor.cs @@ -14,9 +14,9 @@ namespace MQTTnet.Server private readonly IMqttClientSession _clientSession; private readonly IMqttNetChildLogger _logger; - + private bool _isPaused; - + public MqttClientKeepAliveMonitor(IMqttClientSession clientSession, IMqttNetChildLogger logger) { if (logger == null) throw new ArgumentNullException(nameof(logger)); @@ -76,7 +76,7 @@ namespace MQTTnet.Server { _logger.Warning(null, "Client '{0}': Did not receive any packet or keep alive signal.", _clientSession.ClientId); _clientSession.Stop(MqttClientDisconnectType.NotClean); - + return; } @@ -96,7 +96,7 @@ namespace MQTTnet.Server } finally { - _logger.Verbose("Client {0}: Stopped checking keep alive timeout.", _clientSession.ClientId); + _logger.Verbose("Client '{0}': Stopped checking keep alive timeout.", _clientSession.ClientId); } } } diff --git a/Source/MQTTnet/Server/MqttClientSession.cs b/Source/MQTTnet/Server/MqttClientSession.cs index 429fdb45..7879ea6a 100644 --- a/Source/MQTTnet/Server/MqttClientSession.cs +++ b/Source/MQTTnet/Server/MqttClientSession.cs @@ -405,12 +405,12 @@ namespace MQTTnet.Server private void OnAdapterReadingPacketCompleted(object sender, EventArgs e) { - _keepAliveMonitor?.Pause(); + _keepAliveMonitor?.Resume(); } private void OnAdapterReadingPacketStarted(object sender, EventArgs e) { - _keepAliveMonitor?.Resume(); + _keepAliveMonitor?.Pause(); } } }