diff --git a/Source/MQTTnet/Server/MqttClientSessionsManager.cs b/Source/MQTTnet/Server/MqttClientSessionsManager.cs index 8be714d1..456636a2 100644 --- a/Source/MQTTnet/Server/MqttClientSessionsManager.cs +++ b/Source/MQTTnet/Server/MqttClientSessionsManager.cs @@ -238,7 +238,7 @@ namespace MQTTnet.Server { if (_options.UndeliveredMessageInterceptor == null) { - throw new OperationCanceledException(nameof(_options.UndeliveredMessageInterceptor)); + return; } await _options.UndeliveredMessageInterceptor.InterceptApplicationMessagePublishAsync(new MqttApplicationMessageInterceptorContext(sender?.ClientId, sender?.Session?.Items, applicationMessage));