diff --git a/Frameworks/MQTTnet.NetStandard/MqttFactory.cs b/Frameworks/MQTTnet.NetStandard/MqttFactory.cs index ede45c62..50cdddea 100644 --- a/Frameworks/MQTTnet.NetStandard/MqttFactory.cs +++ b/Frameworks/MQTTnet.NetStandard/MqttFactory.cs @@ -98,7 +98,7 @@ namespace MQTTnet _serviceProvider.GetRequiredService>(), clientSessionsManager, _serviceProvider.GetRequiredService(), - _serviceProvider.GetRequiredService>(), + _serviceProvider.GetRequiredService>(), _serviceProvider.GetRequiredService>()); } @@ -119,8 +119,9 @@ namespace MQTTnet public IMqttServer CreateMqttServer(Action configure) { - var options = _serviceProvider.GetRequiredService>(); + if (configure == null) throw new ArgumentNullException(nameof(configure)); + var options = _serviceProvider.GetRequiredService>(); configure(options.Value); return _serviceProvider.GetRequiredService(); diff --git a/Frameworks/MQTTnet.UniversalWindows/MqttFactory.cs b/Frameworks/MQTTnet.UniversalWindows/MqttFactory.cs index 9a0721ff..67b8fe6d 100644 --- a/Frameworks/MQTTnet.UniversalWindows/MqttFactory.cs +++ b/Frameworks/MQTTnet.UniversalWindows/MqttFactory.cs @@ -111,5 +111,15 @@ namespace MQTTnet { return _serviceProvider.GetRequiredService(); } + + public IMqttServer CreateMqttServer(Action configure) + { + if (configure == null) throw new ArgumentNullException(nameof(configure)); + + var options = _serviceProvider.GetRequiredService>(); + configure(options.Value); + + return _serviceProvider.GetRequiredService(); + } } } \ No newline at end of file