diff --git a/Source/MQTTnet/Server/MqttClientMessageQueueInterceptorContext.cs b/Source/MQTTnet/Server/MqttClientMessageQueueInterceptorContext.cs index ca0e2a0..209f8c0 100644 --- a/Source/MQTTnet/Server/MqttClientMessageQueueInterceptorContext.cs +++ b/Source/MQTTnet/Server/MqttClientMessageQueueInterceptorContext.cs @@ -1,12 +1,15 @@ -namespace MQTTnet.Server +using MQTTnet.Protocol; + +namespace MQTTnet.Server { public class MqttClientMessageQueueInterceptorContext { - public MqttClientMessageQueueInterceptorContext(string senderClientId, string receiverClientId, MqttApplicationMessage applicationMessage) + public MqttClientMessageQueueInterceptorContext(string senderClientId, string receiverClientId, MqttApplicationMessage applicationMessage, MqttQualityOfServiceLevel subscriptionQualityOfServiceLevel) { SenderClientId = senderClientId; ReceiverClientId = receiverClientId; ApplicationMessage = applicationMessage; + SubscriptionQualityOfServiceLevel = subscriptionQualityOfServiceLevel; } public string SenderClientId { get; } @@ -16,5 +19,7 @@ public MqttApplicationMessage ApplicationMessage { get; set; } public bool AcceptEnqueue { get; set; } = true; + + public MqttQualityOfServiceLevel SubscriptionQualityOfServiceLevel { get; set; } } }