Browse Source

Refactoring minor issues

release/3.x.x
Christian 6 years ago
parent
commit
d2049d63d6
3 changed files with 2 additions and 3 deletions
  1. +0
    -1
      Frameworks/MQTTnet.NetStandard/Server/MqttClientPendingMessagesQueue.cs
  2. +1
    -1
      Frameworks/MQTTnet.NetStandard/Server/MqttClientSessionsManager.cs
  3. +1
    -1
      Frameworks/MQTTnet.NetStandard/Server/MqttClientSubscriptionsManager.cs

+ 0
- 1
Frameworks/MQTTnet.NetStandard/Server/MqttClientPendingMessagesQueue.cs View File

@@ -1,6 +1,5 @@
using System; using System;
using System.Collections.Concurrent; using System.Collections.Concurrent;
using System.Runtime.CompilerServices;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
using MQTTnet.Adapter; using MQTTnet.Adapter;


+ 1
- 1
Frameworks/MQTTnet.NetStandard/Server/MqttClientSessionsManager.cs View File

@@ -187,7 +187,7 @@ namespace MQTTnet.Server
{ {
foreach (var clientSession in _sessions.Values) foreach (var clientSession in _sessions.Values)
{ {
await clientSession.EnqueueApplicationMessageAsync(applicationMessage);
await clientSession.EnqueueApplicationMessageAsync(applicationMessage).ConfigureAwait(false);
} }
} }
finally finally


+ 1
- 1
Frameworks/MQTTnet.NetStandard/Server/MqttClientSubscriptionsManager.cs View File

@@ -10,8 +10,8 @@ namespace MQTTnet.Server
{ {
public sealed class MqttClientSubscriptionsManager : IDisposable public sealed class MqttClientSubscriptionsManager : IDisposable
{ {
private readonly SemaphoreSlim _semaphore = new SemaphoreSlim(1, 1);
private readonly Dictionary<string, MqttQualityOfServiceLevel> _subscriptions = new Dictionary<string, MqttQualityOfServiceLevel>(); private readonly Dictionary<string, MqttQualityOfServiceLevel> _subscriptions = new Dictionary<string, MqttQualityOfServiceLevel>();
private readonly SemaphoreSlim _semaphore = new SemaphoreSlim(1, 1);
private readonly IMqttServerOptions _options; private readonly IMqttServerOptions _options;
private readonly string _clientId; private readonly string _clientId;




Loading…
Cancel
Save