fix: prevent mqtt message already processed error

BEagle1984 · Sep 26, 2023 · 7eb02e5 · 7eb02e5
1 parent 6700d65
commit 7eb02e5
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/Silverback.Integration.MQTT/Messaging/Broker/Mqtt/ConsumedApplicationMessage.cs b/src/Silverback.Integration.MQTT/Messaging/Broker/Mqtt/ConsumedApplicationMessage.cs
@@ -15,9 +15,7 @@ internal sealed class ConsumedApplicationMessage
         public ConsumedApplicationMessage(MqttApplicationMessageReceivedEventArgs eventArgs)
         {
             EventArgs = eventArgs;
-            Id = eventArgs.ApplicationMessage.UserProperties
-                     ?.FirstOrDefault(header => header.Name == DefaultMessageHeaders.MessageId)?.Value
-                 ?? Guid.NewGuid().ToString();
+            Id = Guid.NewGuid().ToString();
         }
 
         public string Id { get; }