YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-17 01:33:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

rename

Browse Source
This commit is contained in:
Wang Chunlong
2021-03-31 11:56:58 +08:00
parent cf8ea872d3
commit 85b339e6f0
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Server/MqttClientSessionsManager.cs
+2 -2
View File
@@ -237,13 +237,13 @@ namespace MQTTnet.Server
}
}
var clientEndpoint = channelAdapter.Endpoint;
var endpoint = channelAdapter.Endpoint;
await SafeCleanupChannelAsync(channelAdapter).ConfigureAwait(false);
if (clientId != null)
{
await _eventDispatcher.SafeNotifyClientDisconnectedAsync(clientId, disconnectType, clientEndpoint).ConfigureAwait(false);
await _eventDispatcher.SafeNotifyClientDisconnectedAsync(clientId, disconnectType, endpoint).ConfigureAwait(false);
}
}
Source/MQTTnet/Server/MqttServerClientDisconnectedEventArgs.cs
+1 -1
View File
@@ -19,6 +19,6 @@ namespace MQTTnet.Server
public MqttClientDisconnectType DisconnectType { get; }
public string Endpoint { get; set; }
public string Endpoint { get; }
}
}
Source/MQTTnet/Server/MqttServerEventDispatcher.cs
+2 -2
View File
@@ -44,7 +44,7 @@ namespace MQTTnet.Server
}
}
public async Task SafeNotifyClientDisconnectedAsync(string clientId, MqttClientDisconnectType disconnectType, string clientEndpoint)
public async Task SafeNotifyClientDisconnectedAsync(string clientId, MqttClientDisconnectType disconnectType, string endpoint)
{
try
{
@@ -54,7 +54,7 @@ namespace MQTTnet.Server
return;
}
await handler.HandleClientDisconnectedAsync(new MqttServerClientDisconnectedEventArgs(clientId, disconnectType, clientEndpoint)).ConfigureAwait(false);
await handler.HandleClientDisconnectedAsync(new MqttServerClientDisconnectedEventArgs(clientId, disconnectType, endpoint)).ConfigureAwait(false);
}
catch (Exception exception)
{