diff --git a/Source/MQTTnet.AspnetCore/Internal/MqttChannel.cs b/Source/MQTTnet.AspnetCore/Internal/MqttChannel.cs index b3d0b360b..b709838c0 100644 --- a/Source/MQTTnet.AspnetCore/Internal/MqttChannel.cs +++ b/Source/MQTTnet.AspnetCore/Internal/MqttChannel.cs @@ -86,7 +86,7 @@ private static bool AllowPacketFragmentation(IHttpContextFeature? _httpContextFe } } - return null; + return remoteEndPoint; } private static bool IsTlsConnection(IHttpContextFeature? _httpContextFeature, ITlsConnectionFeature? tlsConnectionFeature)