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

Moved undeliveredMessageInterceptor to local variable to avoid threading issues.

Browse Source
This commit is contained in:
SeppPenner
2020-06-11 12:41:48 +02:00
parent a407fc381b
commit 257211fc7a
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Server/MqttClientSessionsManager.cs
+4 -2
View File
@@ -238,12 +238,14 @@ namespace MQTTnet.Server
if (deliveryCount == 0) if (deliveryCount == 0)
{ {
if (_options.UndeliveredMessageInterceptor == null) var undeliveredMessageInterceptor = _options.UndeliveredMessageInterceptor;
if (undeliveredMessageInterceptor == null)
{ {
return; return;
} }
await _options.UndeliveredMessageInterceptor.InterceptApplicationMessagePublishAsync(new MqttApplicationMessageInterceptorContext(sender?.ClientId, sender?.Session?.Items, applicationMessage)); await undeliveredMessageInterceptor.InterceptApplicationMessagePublishAsync(new MqttApplicationMessageInterceptorContext(sender?.ClientId, sender?.Session?.Items, applicationMessage));
} }
} }
catch (OperationCanceledException) catch (OperationCanceledException)