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

Restore console log of test app

Browse Source
This commit is contained in:
Christian Kratky
2017-10-25 23:39:57 +02:00
parent 3b366f91fc
commit f85721fbf5
2 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Tests/MQTTnet.TestApp.NetCore/ClientTest.cs
+7 -7
View File
@@ -17,14 +17,14 @@ namespace MQTTnet.TestApp.NetCore
{
ClientId = "XYZ",
CleanSession = true,
////ChannelOptions = new MqttClientTcpOptions
////{
//// Server = "localhost"
////},
ChannelOptions = new MqttClientWebSocketOptions
ChannelOptions = new MqttClientTcpOptions
{
Uri = "localhost"
}
Server = "localhost"
},
////ChannelOptions = new MqttClientWebSocketOptions
////{
//// Uri = "localhost"
////}
};
var factory = new MqttFactory();
Tests/MQTTnet.TestApp.NetCore/ServerTest.cs
+2 -1
View File
@@ -49,6 +49,7 @@ namespace MQTTnet.TestApp.NetCore
});
var serviceProvider = services.BuildServiceProvider();
serviceProvider.GetRequiredService<ILoggerFactory>().AddConsole();
//var certificate = new X509Certificate(@"C:\certs\test\test.cer", "");
//options.TlsEndpointOptions.Certificate = certificate.Export(X509ContentType.Cert);
@@ -56,7 +57,7 @@ namespace MQTTnet.TestApp.NetCore
//options.DefaultEndpointOptions.IsEnabled = true;
//options.TlsEndpointOptions.IsEnabled = false;
var mqttServer = serviceProvider.GetRequiredService<IMqttServer>();
var mqttServer = new MqttFactory(serviceProvider).CreateMqttServer();
mqttServer.ClientDisconnected += (s, e) =>
{
Console.Write("Client disconnected event fired.");