RavenDB-29429 Fix issue with fifo queue

djordjedjukic · Jan 9, 2025 · 62642be · 62642be
1 parent 5fae62a
commit 62642be
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/Raven.Server/Documents/ETL/Providers/Queue/AmazonSqs/AmazonSqsEtl.cs b/src/Raven.Server/Documents/ETL/Providers/Queue/AmazonSqs/AmazonSqsEtl.cs
@@ -59,7 +59,7 @@ protected override int PublishMessages(List<QueueWithItems<AmazonSqsItem>> items
 
         foreach (QueueWithItems<AmazonSqsItem> queue in itemsPerQueue)
         {
-            string queueName = queue.Name.ToLower();
+            string queueName = queue.Name;
             bool isFifoQueue = queueName.EndsWith(FifoQueueIdentifier);
 
             if (_queueClient == null)
@@ -206,7 +206,8 @@ private void SendMessagesOneByOne(string queueName,
                 {
                     MessageGroupId = message.MessageGroupId,
                     QueueUrl = GetQueueUrl(_queueClient, queueName),
-                    MessageBody = message.MessageBody
+                    MessageBody = message.MessageBody,
+                    MessageDeduplicationId = message.MessageDeduplicationId
                 };
 
                 AsyncHelpers.RunSync(() => _queueClient.SendMessageAsync(sendMessageRequest));