g82tt/KinginfoGateway
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

暂时屏蔽mqttserver 遗留消息错误

Browse Source
This commit is contained in:
Kimdiego2098
2023-10-23 20:51:11 +08:00
parent bbcf7c722a
commit 5d0a2ffae0
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
framework/Plugin/ThingsGateway.Plugin.Mqtt/MqttServer.cs
View File

@@ -256,7 +256,8 @@ public class MqttServer : UpLoadBase
}
private void Log_LogMessagePublished(object sender, MqttNetLogMessagePublishedEventArgs e)
{
LogMessage.LogOut(e.LogMessage.Level, e.LogMessage.Source, e.LogMessage.Message, e.LogMessage.Exception);
if (e.LogMessage.Exception is not ArgumentNullException)
LogMessage.LogOut(e.LogMessage.Level, e.LogMessage.Source, e.LogMessage.Message, e.LogMessage.Exception);
}
private void DeviceStatusChange(CollectDeviceRunTime collectDeviceRunTime)
{

3
framework/Web/ThingsGateway.Gateway.Application/Workers/ManageGateway/ManageGatewayWorker.cs
View File

@@ -475,7 +475,8 @@ public class ManageGatewayWorker : BackgroundService
}
private void Log_LogMessagePublished(object sender, MqttNetLogMessagePublishedEventArgs e)
{
_clientLogger.LogOut(e.LogMessage.Level, e.LogMessage.Source, e.LogMessage.Message, e.LogMessage.Exception);
if (e.LogMessage.Exception is not ArgumentNullException)
_clientLogger.LogOut(e.LogMessage.Level, e.LogMessage.Source, e.LogMessage.Message, e.LogMessage.Exception);
}
private void ServerLog_LogMessagePublished(object sender, MqttNetLogMessagePublishedEventArgs e)
{