From 7292cedd2f8c658f5400896c7f8e1297ee4f4f56 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Mon, 19 Nov 2018 00:17:19 +0100 Subject: [PATCH] Encode ConnAck packet. --- Source/MQTTnet/Formatter/V500/MqttV500PacketFormatter.cs | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/Source/MQTTnet/Formatter/V500/MqttV500PacketFormatter.cs b/Source/MQTTnet/Formatter/V500/MqttV500PacketFormatter.cs index 08b8491b..34a93405 100644 --- a/Source/MQTTnet/Formatter/V500/MqttV500PacketFormatter.cs +++ b/Source/MQTTnet/Formatter/V500/MqttV500PacketFormatter.cs @@ -100,9 +100,18 @@ namespace MQTTnet.Formatter.V500 WriteProperty(MqttMessagePropertyID.SessionExpiryInterval, packet.SessionExpiryIntervalProperty, packetWriter); WriteProperty(MqttMessagePropertyID.AuthenticationMethod, packet.AuthenticationMethodProperty, packetWriter); WriteProperty(MqttMessagePropertyID.AuthenticationData, packet.AuthenticationDataProperty, packetWriter); + WriteProperty(MqttMessagePropertyID.RetainAvailable, packet.RetainAvailableProperty, packetWriter); WriteProperty(MqttMessagePropertyID.ReceiveMaximum, packet.ReceiveMaximumProperty, packetWriter); + WriteProperty(MqttMessagePropertyID.AssignedClientIdentifer, packet.AssignedClientIdentifierProperty, packetWriter); WriteProperty(MqttMessagePropertyID.TopicAlias, packet.TopicAliasMaximumProperty, packetWriter); + WriteProperty(MqttMessagePropertyID.ReasonString, packet.ReasonStringProperty, packetWriter); WriteProperty(MqttMessagePropertyID.MaximumPacketSize, packet.MaximumPacketSizeProperty, packetWriter); + WriteProperty(MqttMessagePropertyID.WildcardSubscriptionAvailable, packet.WildcardSubscriptionAvailableProperty, packetWriter); + WriteProperty(MqttMessagePropertyID.SubscriptionIdentifierAvailable, packet.SubscriptionIdentifiersAvailableProperty, packetWriter); + WriteProperty(MqttMessagePropertyID.SharedSubscriptionAvailable, packet.SharedSubscriptionAvailableProperty, packetWriter); + WriteProperty(MqttMessagePropertyID.ServerKeepAlive, packet.ServerKeepAliveProperty, packetWriter); + WriteProperty(MqttMessagePropertyID.ResponseInformation, packet.ResponseInformationProperty, packetWriter); + WriteProperty(MqttMessagePropertyID.ServerReference, packet.ServerReferenceProperty, packetWriter); WriteUserProperties(packet.UserPropertiesProperty, packetWriter); return MqttPacketWriter.BuildFixedHeader(MqttControlPacketType.ConnAck);