Fix NullRefException when cancelling the server.

This commit is contained in:
Christian
2019-02-23 10:40:17 +01:00
parent 09718a00e7
commit 3b02a5f6aa
2 changed files with 5 additions and 2 deletions
@@ -170,6 +170,11 @@ namespace MQTTnet.Server
{ {
try try
{ {
if (cancellationToken.IsCancellationRequested)
{
return;
}
var enqueuedApplicationMessage = _messageQueue.Take(cancellationToken); var enqueuedApplicationMessage = _messageQueue.Take(cancellationToken);
var sender = enqueuedApplicationMessage.Sender; var sender = enqueuedApplicationMessage.Sender;
@@ -2,8 +2,6 @@
using MQTTnet.Diagnostics; using MQTTnet.Diagnostics;
using MQTTnet.Extensions.ManagedClient; using MQTTnet.Extensions.ManagedClient;
using System; using System;
using System.Collections.Generic;
using System.Text;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;