diff --git a/Source/MQTTnet/Server/MqttRetainedMessagesManager.cs b/Source/MQTTnet/Server/MqttRetainedMessagesManager.cs index 8151fc00..2e6af16a 100644 --- a/Source/MQTTnet/Server/MqttRetainedMessagesManager.cs +++ b/Source/MQTTnet/Server/MqttRetainedMessagesManager.cs @@ -61,7 +61,7 @@ namespace MQTTnet.Server using (await _messagesLock.WaitAsync().ConfigureAwait(false)) { var saveIsRequired = false; - var hasPayload = applicationMessage.Payload?.Any() == true; + var hasPayload = applicationMessage.Payload != null && applicationMessage.Payload.Length > 0; if (!hasPayload) {