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

MQTTnet: Adjusted UndeliveredMessageInterceptor handler to return if it's null instead of throwing an exception.

Browse Source
This commit is contained in:
SeppPenner
2020-06-10 11:52:55 +02:00
parent 75dfe68a94
commit c20142671f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Server/MqttClientSessionsManager.cs
+1 -1
View File
@@ -238,7 +238,7 @@ namespace MQTTnet.Server
{ {
if (_options.UndeliveredMessageInterceptor == null) if (_options.UndeliveredMessageInterceptor == null)
{ {
throw new OperationCanceledException(nameof(_options.UndeliveredMessageInterceptor)); return;
} }
await _options.UndeliveredMessageInterceptor.InterceptApplicationMessagePublishAsync(new MqttApplicationMessageInterceptorContext(sender?.ClientId, sender?.Session?.Items, applicationMessage)); await _options.UndeliveredMessageInterceptor.InterceptApplicationMessagePublishAsync(new MqttApplicationMessageInterceptorContext(sender?.ClientId, sender?.Session?.Items, applicationMessage));