YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-16 09:13:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix broken code.

Browse Source
This commit is contained in:
Christian Kratky
2019-04-18 00:09:19 +02:00
parent a8434d1b58
commit 519bb05aac
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Formatter/V5/MqttV500DataConverter.cs
+12 -5
View File
@@ -189,14 +189,21 @@ namespace MQTTnet.Formatter.V5
public MqttClientPublishResult CreatePublishResult(MqttPubAckPacket pubAckPacket)
{
var reasonCode = MqttClientPublishReasonCode.Success;
if (pubAckPacket != null)
{
// QoS 0 has no response. So we treat it as a success always.
reasonCode = (MqttClientPublishReasonCode)pubAckPacket.ReasonCode;
}
var result = new MqttClientPublishResult
{
// Both enums share the same values.
ReasonCode = (MqttClientPublishReasonCode)pubAckPacket.ReasonCode.Value,
ReasonString = pubAckPacket.Properties?.ReasonString,
UserProperties = pubAckPacket.Properties?.UserProperties
ReasonCode = reasonCode,
ReasonString = pubAckPacket?.Properties?.ReasonString,
UserProperties = pubAckPacket?.Properties?.UserProperties
};
return result;
}
@@ -227,7 +234,7 @@ namespace MQTTnet.Formatter.V5
ReasonString = pubCompPacket.Properties?.ReasonString,
UserProperties = pubCompPacket.Properties?.UserProperties
};
if (pubRecPacket.ReasonCode.HasValue)
{
// Both enums share the same values.