handle headers with string keys

nasark · Nov 28, 2023 · 1cf7daf · 1cf7daf
1 parent e4560c3
commit 1cf7daf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/manageiq/messaging/kafka/common.rb b/lib/manageiq/messaging/kafka/common.rb
@@ -116,7 +116,7 @@ def message_header_keys
 
         def parse_message_headers(headers)
           return [nil, nil, nil] unless headers.kind_of?(Hash)
-          headers.values_at(*message_header_keys)
+          headers.with_indifferent_access.values_at(*message_header_keys)
         end
 
         def event_header_keys
@@ -125,7 +125,7 @@ def event_header_keys
 
         def parse_event_headers(headers)
           return [nil, nil] unless headers.kind_of?(Hash)
-          headers.values_at(*event_header_keys)
+          headers.with_indifferent_access.values_at(*event_header_keys)
         end
       end
     end