Merge pull request #77 from nedimtokic/astarte-sdk-csharp-message-que…

…ue-order Order stored messages
astarte-platform · Jul 19, 2024 · d44adf6 · d44adf6
2 parents d385856 + 3c65c4f
commit d44adf6
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/AstarteDeviceSDKCSharp/Transport/MQTT/AstarteMqttTransport.cs b/AstarteDeviceSDKCSharp/Transport/MQTT/AstarteMqttTransport.cs
@@ -171,7 +171,7 @@ public override async Task Connect()
                 .WithAutoReconnectDelay(TimeSpan.FromSeconds(5))
                 .WithMaxPendingMessages(10000)
                 .WithPendingMessagesOverflowStrategy(
-                    MQTTnet.Server.MqttPendingMessagesOverflowStrategy.DropOldestQueuedMessage)
+                    MQTTnet.Server.MqttPendingMessagesOverflowStrategy.DropNewMessage)
                 .Build();
 
             if (!_client.IsStarted)

diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -15,6 +15,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Add a fallout strategy for individual failed messages.
 - Resend failed messages stored in the cache memory.
 
+### Fixed
+- Resend stored messages in the order in which they were streamed
+by the user
+
 ## [0.6.0] - 2023-12-18
 ### Added
 - Add the capability to update the introspection dynamically.