From 2d59b5c1ac0eff9648b84b9a4b663ea22768123e Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Tue, 23 Apr 2019 14:49:19 +0200 Subject: [PATCH] Refactoring. --- Source/MQTTnet/Server/IMqttServer.cs | 4 ++-- Source/MQTTnet/Server/MqttServer.cs | 4 ++-- Source/MQTTnet/Server/Status/IMqttSessionStatus.cs | 2 -- Source/MQTTnet/Server/Status/MqttSessionStatus.cs | 2 -- 4 files changed, 4 insertions(+), 8 deletions(-) diff --git a/Source/MQTTnet/Server/IMqttServer.cs b/Source/MQTTnet/Server/IMqttServer.cs index cf1681dd..c080f4e8 100644 --- a/Source/MQTTnet/Server/IMqttServer.cs +++ b/Source/MQTTnet/Server/IMqttServer.cs @@ -19,8 +19,8 @@ namespace MQTTnet.Server Task> GetClientStatusAsync(); Task> GetSessionStatusAsync(); - Task> GetRetainedMessagesAsync(); - Task ClearRetainedMessagesAsync(); + Task> GetRetainedApplicationMessagesAsync(); + Task ClearRetainedApplicationMessagesAsync(); Task SubscribeAsync(string clientId, ICollection topicFilters); Task UnsubscribeAsync(string clientId, ICollection topicFilters); diff --git a/Source/MQTTnet/Server/MqttServer.cs b/Source/MQTTnet/Server/MqttServer.cs index 0055639a..b2c32f45 100644 --- a/Source/MQTTnet/Server/MqttServer.cs +++ b/Source/MQTTnet/Server/MqttServer.cs @@ -77,7 +77,7 @@ namespace MQTTnet.Server return _clientSessionsManager.GetSessionStatusAsync(); } - public Task> GetRetainedMessagesAsync() + public Task> GetRetainedApplicationMessagesAsync() { return _retainedMessagesManager.GetMessagesAsync(); } @@ -179,7 +179,7 @@ namespace MQTTnet.Server } } - public Task ClearRetainedMessagesAsync() + public Task ClearRetainedApplicationMessagesAsync() { return _retainedMessagesManager?.ClearMessagesAsync(); } diff --git a/Source/MQTTnet/Server/Status/IMqttSessionStatus.cs b/Source/MQTTnet/Server/Status/IMqttSessionStatus.cs index ada8efed..349f715e 100644 --- a/Source/MQTTnet/Server/Status/IMqttSessionStatus.cs +++ b/Source/MQTTnet/Server/Status/IMqttSessionStatus.cs @@ -6,8 +6,6 @@ namespace MQTTnet.Server.Status { string ClientId { get; set; } - bool IsConnected { get; } - long PendingApplicationMessagesCount { get; set; } Task ClearPendingApplicationMessagesAsync(); diff --git a/Source/MQTTnet/Server/Status/MqttSessionStatus.cs b/Source/MQTTnet/Server/Status/MqttSessionStatus.cs index 401fc379..451644c6 100644 --- a/Source/MQTTnet/Server/Status/MqttSessionStatus.cs +++ b/Source/MQTTnet/Server/Status/MqttSessionStatus.cs @@ -17,8 +17,6 @@ namespace MQTTnet.Server.Status public string ClientId { get; set; } public long PendingApplicationMessagesCount { get; set; } - - public bool IsConnected { get; set; } public DateTime CreatedTimestamp { get; set; }