From e6de4d014e0049d61a9d3e07f1450bac168bf67b Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Mon, 4 Jun 2018 21:19:15 +0200 Subject: [PATCH] Update client test app --- Tests/MQTTnet.TestApp.NetCore/ClientTest.cs | 29 ++++++++------------- 1 file changed, 11 insertions(+), 18 deletions(-) diff --git a/Tests/MQTTnet.TestApp.NetCore/ClientTest.cs b/Tests/MQTTnet.TestApp.NetCore/ClientTest.cs index dd4a1bc0..b943bc3f 100644 --- a/Tests/MQTTnet.TestApp.NetCore/ClientTest.cs +++ b/Tests/MQTTnet.TestApp.NetCore/ClientTest.cs @@ -12,25 +12,18 @@ namespace MQTTnet.TestApp.NetCore { try { - var options = new MqttClientOptions - { - ClientId = "XYZ", - CleanSession = true, - ChannelOptions = new MqttClientTcpOptions - { - //Server = "localhost", - Server = "192.168.1.174" - }, - //ChannelOptions = new MqttClientWebSocketOptions - //{ - // Uri = "ws://localhost:59690/mqtt" - //} - }; + MqttNetConsoleLogger.ForwardToConsole(); var factory = new MqttFactory(); - var client = factory.CreateMqttClient(); - + var clientOptions = new MqttClientOptions + { + ChannelOptions = new MqttClientTcpOptions + { + Server = "localhost" + } + }; + client.ApplicationMessageReceived += (s, e) => { Console.WriteLine("### RECEIVED APPLICATION MESSAGE ###"); @@ -57,7 +50,7 @@ namespace MQTTnet.TestApp.NetCore try { - await client.ConnectAsync(options); + await client.ConnectAsync(clientOptions); } catch { @@ -67,7 +60,7 @@ namespace MQTTnet.TestApp.NetCore try { - await client.ConnectAsync(options); + await client.ConnectAsync(clientOptions); } catch (Exception exception) {