vbBerni
5 years ago
1 changed files with 8 additions and 2 deletions
Unified View
Diff Options
+ 8
- 2
Source/MQTTnet.Extensions.ManagedClient/ManagedMqttClient.cs
View File
| @@ -387,7 +387,10 @@ namespace MQTTnet.Extensions.ManagedClient | |||||
| //removed it, in which case we don't want to do anything. | //removed it, in which case we don't want to do anything. | ||||
| _messageQueue.RemoveFirst(i => i.Id.Equals(message.Id)); | _messageQueue.RemoveFirst(i => i.Id.Equals(message.Id)); | ||||
| } | } | ||||
| _storageManager?.RemoveAsync(message).GetAwaiter().GetResult(); | |||||
| if (_storageManager != null) | |||||
| { | |||||
| _storageManager.RemoveAsync(message).GetAwaiter().GetResult(); | |||||
| } | |||||
| } | } | ||||
| catch (MqttCommunicationException exception) | catch (MqttCommunicationException exception) | ||||
| { | { | ||||
| @@ -408,7 +411,10 @@ namespace MQTTnet.Extensions.ManagedClient | |||||
| { | { | ||||
| _messageQueue.RemoveFirst(i => i.Id.Equals(message.Id)); | _messageQueue.RemoveFirst(i => i.Id.Equals(message.Id)); | ||||
| } | } | ||||
| _storageManager?.RemoveAsync(message).GetAwaiter().GetResult(); | |||||
| if (_storageManager != null) | |||||
| { | |||||
| _storageManager.RemoveAsync(message).GetAwaiter().GetResult(); | |||||
| } | |||||
| } | } | ||||
| } | } | ||||
| catch (Exception exception) | catch (Exception exception) | ||||