diff --git a/Source/MQTTnet/MqttApplicationMessageBuilder.cs b/Source/MQTTnet/MqttApplicationMessageBuilder.cs index c265e4d1..bc2d9b86 100644 --- a/Source/MQTTnet/MqttApplicationMessageBuilder.cs +++ b/Source/MQTTnet/MqttApplicationMessageBuilder.cs @@ -1,4 +1,5 @@ -using System.Collections.Generic; +using System; +using System.Collections.Generic; using System.IO; using System.Linq; using System.Text; @@ -103,6 +104,16 @@ namespace MQTTnet return this; } + public MqttApplicationMessageBuilder WithQualityOfServiceLevel(int qualityOfServiceLevel) + { + if (qualityOfServiceLevel < 0 || qualityOfServiceLevel > 2) + { + throw new ArgumentOutOfRangeException(nameof(qualityOfServiceLevel)); + } + + return WithQualityOfServiceLevel((MqttQualityOfServiceLevel)qualityOfServiceLevel); + } + public MqttApplicationMessageBuilder WithRetainFlag(bool value = true) { _retain = value;