Fix minor bug in MqttV5PacketEncoder.cs

dotnet · Feb 29, 2024 · 6a20c76 · 6a20c76
1 parent f82d382
commit 6a20c76
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/Source/MQTTnet/Formatter/V5/MqttV5PacketEncoder.cs b/Source/MQTTnet/Formatter/V5/MqttV5PacketEncoder.cs
@@ -279,7 +279,7 @@ byte EncodePubAckPacket(MqttPubAckPacket packet)
             _propertiesWriter.WriteReasonString(packet.ReasonString);
             _propertiesWriter.WriteUserProperties(packet.UserProperties);
 
-            if (_bufferWriter.Length > 0 || packet.ReasonCode != MqttPubAckReasonCode.Success)
+            if (_propertiesWriter.Length > 0 || packet.ReasonCode != MqttPubAckReasonCode.Success)
             {
                 _bufferWriter.WriteByte((byte)packet.ReasonCode);
                 _propertiesWriter.WriteTo(_bufferWriter);
@@ -375,7 +375,7 @@ byte EncodePubRecPacket(MqttPubRecPacket packet)
 
             _bufferWriter.WriteTwoByteInteger(packet.PacketIdentifier);
 
-            if (_bufferWriter.Length > 0 || packet.ReasonCode != MqttPubRecReasonCode.Success)
+            if (_propertiesWriter.Length > 0 || packet.ReasonCode != MqttPubRecReasonCode.Success)
             {
                 _bufferWriter.WriteByte((byte)packet.ReasonCode);
                 _propertiesWriter.WriteTo(_bufferWriter);
@@ -534,4 +534,4 @@ static void ThrowIfPacketIdentifierIsInvalid(ushort packetIdentifier, MqttPacket
             }
         }
     }
-}
+}