YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-20 03:24:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add new overloads.

Browse Source
This commit is contained in:
Christian Kratky
2018-07-07 22:46:07 +02:00
parent acbf1226ab
commit dee0adcd8c
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/MqttFactory.cs
+10 -3
View File
@@ -22,12 +22,19 @@ namespace MQTTnet
return new MqttClient(new MqttClientAdapterFactory(), logger); return new MqttClient(new MqttClientAdapterFactory(), logger);
} }
public IMqttClient CreateMqttClient(IMqttNetLogger logger, IMqttClientAdapterFactory mqttClientAdapterFactory) public IMqttClient CreateMqttClient(IMqttClientAdapterFactory adapterFactory)
{
if (adapterFactory == null) throw new ArgumentNullException(nameof(adapterFactory));
return new MqttClient(adapterFactory, new MqttNetLogger());
}
public IMqttClient CreateMqttClient(IMqttNetLogger logger, IMqttClientAdapterFactory adapterFactory)
{ {
if (logger == null) throw new ArgumentNullException(nameof(logger)); if (logger == null) throw new ArgumentNullException(nameof(logger));
if (mqttClientAdapterFactory == null) throw new ArgumentNullException(nameof(mqttClientAdapterFactory)); if (adapterFactory == null) throw new ArgumentNullException(nameof(adapterFactory));
return new MqttClient(mqttClientAdapterFactory, logger); return new MqttClient(adapterFactory, logger);
} }
public IMqttServer CreateMqttServer() public IMqttServer CreateMqttServer()