fix: give messageid in amqp plugin (#601)

aneoconsulting · Jan 29, 2024 · 3067d78 · 3067d78
2 parents c5f1f2d + 2090237
commit 3067d78
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/Adaptors/Amqp/src/PushQueueStorage.cs b/Adaptors/Amqp/src/PushQueueStorage.cs
@@ -108,7 +108,11 @@ await messages.ParallelForEach(new ParallelTaskOptions(cancellationToken),
                                                                           {
                                                                             Priority = (byte)internalPriority,
                                                                           },
-                                                                 Properties = new Properties(),
+                                                                 Properties = new Properties
+                                                                              {
+                                                                                MessageId = Guid.NewGuid()
+                                                                                                .ToString(),
+                                                                              },
                                                                }))
                   .ConfigureAwait(false);