From 7ed5580352571dcf1e0bb349c638b74e925d15b5 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Fri, 22 Mar 2019 21:08:38 +0100 Subject: [PATCH] Fix breaking changes. --- Tests/MQTTnet.Core.Tests/ManagedMqttClientTests.cs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/Tests/MQTTnet.Core.Tests/ManagedMqttClientTests.cs b/Tests/MQTTnet.Core.Tests/ManagedMqttClientTests.cs index 2182407f..10d234c1 100644 --- a/Tests/MQTTnet.Core.Tests/ManagedMqttClientTests.cs +++ b/Tests/MQTTnet.Core.Tests/ManagedMqttClientTests.cs @@ -2,6 +2,7 @@ using System.Threading.Tasks; using Microsoft.VisualStudio.TestTools.UnitTesting; using MQTTnet.Client; +using MQTTnet.Client.Connecting; using MQTTnet.Client.Options; using MQTTnet.Diagnostics; using MQTTnet.Extensions.ManagedClient; @@ -70,7 +71,7 @@ namespace MQTTnet.Tests var recievingClient = await testEnvironment.ConnectClientAsync(); await recievingClient.SubscribeAsync("My/last/will"); - recievingClient.UseReceivedApplicationMessageHandler(context => Interlocked.Increment(ref receivedMessagesCount)); + recievingClient.UseApplicationMessageReceivedHandler(context => Interlocked.Increment(ref receivedMessagesCount)); dyingManagedClient.Dispose(); @@ -94,7 +95,7 @@ namespace MQTTnet.Tests .WithTcpServer("localhost", testEnvironment.ServerPort); TaskCompletionSource connected = new TaskCompletionSource(); - managedClient.Connected += (s, e) => { connected.SetResult(true); }; + managedClient.ConnectedHandler = new MqttClientConnectedHandlerDelegate(e => { connected.SetResult(true);}); await managedClient.StartAsync(new ManagedMqttClientOptionsBuilder() .WithClientOptions(clientOptions)