Fix requeue for FIFO queues

ruby-shoryuken · Feb 13, 2018 · 48fcb42 · 48fcb42
1 parent ddeb454
commit 48fcb42
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/bin/cli/sqs.rb b/bin/cli/sqs.rb
@@ -8,13 +8,14 @@ class SQS < Base
 
       no_commands do
         def normalize_dump_message(message)
-          attributes = message[:attributes]
+          # symbolize_keys is needed for keeping it compatible with `requeue`
+          attributes = message[:attributes].symbolize_keys
           {
             id: message[:message_id],
             message_body: message[:body],
             message_attributes: message[:message_attributes],
-            message_deduplication_id: attributes['MessageDeduplicationId'],
-            message_group_id: attributes['MessageGroupId']
+            message_deduplication_id: attributes[:MessageDeduplicationId],
+            message_group_id: attributes[:MessageGroupId]
           }
         end