MTConnectMqttEntityServer: set correct qos for CreateMessage variants

victoririzarx3d · victoririzarx3d · commit 3e26bf20a7d8 · 2024-10-15T13:08:07.000+02:00
diff --git a/libraries/MTConnect.NET-MQTT/MTConnectMqttEntityServer.cs b/libraries/MTConnect.NET-MQTT/MTConnectMqttEntityServer.cs
@@ -81,6 +81,7 @@ private MqttApplicationMessage CreateMessage(IDevice device)
                     messageBuilder.WithTopic(topic);
                     messageBuilder.WithPayload(formatResult.Content);
                     messageBuilder.WithRetainFlag(true);
+                    messageBuilder.WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce);
                     return messageBuilder.Build();
                 }
             }
@@ -167,6 +168,7 @@ private MqttApplicationMessage CreateMessage(IObservation observation)
                         messageBuilder.WithTopic(topic);
                         messageBuilder.WithPayload(formatResult.Content);
                         messageBuilder.WithRetainFlag(true);
+                        messageBuilder.WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce);
                         return messageBuilder.Build();
                     }
                 }
@@ -198,6 +200,7 @@ private MqttApplicationMessage CreateMessage(IEnumerable<IObservation> observati
                         messageBuilder.WithTopic(topic);
                         messageBuilder.WithPayload(formatResult.Content);
                         messageBuilder.WithRetainFlag(true);
+                        messageBuilder.WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce);
                         return messageBuilder.Build();
                     }
                 }
@@ -250,6 +253,7 @@ private MqttApplicationMessage CreateMessage(IAsset asset)
                     messageBuilder.WithTopic(topic);
                     messageBuilder.WithPayload(formatResult.Content);
                     messageBuilder.WithRetainFlag(true);
+                    messageBuilder.WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce);
                     return messageBuilder.Build();
                 }
             }

Original file line number	Diff line number	Diff line change
`@@ -81,6 +81,7 @@ private MqttApplicationMessage CreateMessage(IDevice device)`
`81`	`81`	`messageBuilder.WithTopic(topic);`
`82`	`82`	`messageBuilder.WithPayload(formatResult.Content);`
`83`	`83`	`messageBuilder.WithRetainFlag(true);`
	`84`	`+ messageBuilder.WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce);`
`84`	`85`	`return messageBuilder.Build();`
`85`	`86`	`}`
`86`	`87`	`}`
`@@ -167,6 +168,7 @@ private MqttApplicationMessage CreateMessage(IObservation observation)`
`167`	`168`	`messageBuilder.WithTopic(topic);`
`168`	`169`	`messageBuilder.WithPayload(formatResult.Content);`
`169`	`170`	`messageBuilder.WithRetainFlag(true);`
	`171`	`+ messageBuilder.WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce);`
`170`	`172`	`return messageBuilder.Build();`
`171`	`173`	`}`
`172`	`174`	`}`
`@@ -198,6 +200,7 @@ private MqttApplicationMessage CreateMessage(IEnumerable<IObservation> observati`
`198`	`200`	`messageBuilder.WithTopic(topic);`
`199`	`201`	`messageBuilder.WithPayload(formatResult.Content);`
`200`	`202`	`messageBuilder.WithRetainFlag(true);`
	`203`	`+ messageBuilder.WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce);`
`201`	`204`	`return messageBuilder.Build();`
`202`	`205`	`}`
`203`	`206`	`}`
`@@ -250,6 +253,7 @@ private MqttApplicationMessage CreateMessage(IAsset asset)`
`250`	`253`	`messageBuilder.WithTopic(topic);`
`251`	`254`	`messageBuilder.WithPayload(formatResult.Content);`
`252`	`255`	`messageBuilder.WithRetainFlag(true);`
	`256`	`+ messageBuilder.WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtLeastOnce);`
`253`	`257`	`return messageBuilder.Build();`
`254`	`258`	`}`
`255`	`259`	`}`