diff --git a/Source/MQTTnet/Server/MqttServer.cs b/Source/MQTTnet/Server/MqttServer.cs index f14ade4e..054467a7 100644 --- a/Source/MQTTnet/Server/MqttServer.cs +++ b/Source/MQTTnet/Server/MqttServer.cs @@ -229,7 +229,14 @@ namespace MQTTnet.Server if (_eventContainer.InterceptingPublishEvent.HasHandlers) { - var interceptingPublishEventArgs = new InterceptingPublishEventArgs(applicationMessage, _cancellationTokenSource.Token, injectedApplicationMessage.SenderClientId, _sessionItems); + var interceptingPublishEventArgs = new InterceptingPublishEventArgs + { + ApplicationMessage = applicationMessage, + CancellationToken = _cancellationTokenSource.Token, + ClientId = injectedApplicationMessage.SenderClientId, + SessionItems = _sessionItems + }; + await _eventContainer.InterceptingPublishEvent.InvokeAsync(interceptingPublishEventArgs).ConfigureAwait(false); applicationMessage = interceptingPublishEventArgs.ApplicationMessage;