Merge branch 'wait-for-suback' into 'master'

Wait for suback See merge request GeorgeHahn/Charlotte!5
GeorgeHahn · Aug 31, 2018 · 55df81e · 55df81e
2 parents 25ec794 + dc1ce3f
commit 55df81e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/Charlotte/MqttRouter.cs b/Charlotte/MqttRouter.cs
@@ -60,7 +60,8 @@ private void MqttMsgReceived(MqttApplicationMessage msg)
                 }
 
                 // TODO: Subscribe QoS customization
-                _connection.SubscribeAsync(sub, MqttQualityOfService.AtMostOnce);
+                var suback = _connection.SubscribeAsync(sub, MqttQualityOfService.AtLeastOnce);
+                suback.Wait();
                 lock (_handlers)
                 {
                     _handlers.Add(new MqttHandler(topic, value));