From fd789417e769b2e6d7cd8cb457d5aa5ca3c65803 Mon Sep 17 00:00:00 2001 From: Marc Sallin Date: Tue, 25 Aug 2020 00:50:30 +0200 Subject: [PATCH] Extend MqttClientMessageQueueInterceptorContext to expose SubscriptionQualityOfServiceLevel --- .../Server/MqttClientMessageQueueInterceptorContext.cs | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) 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; } } }