From 1cf7daf655616cc6c522bfaca6ca83bface4938e Mon Sep 17 00:00:00 2001 From: Nasar Khan Date: Tue, 28 Nov 2023 16:14:29 -0500 Subject: [PATCH] handle headers with string keys --- lib/manageiq/messaging/kafka/common.rb | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/manageiq/messaging/kafka/common.rb b/lib/manageiq/messaging/kafka/common.rb index 7859e67..dd02037 100644 --- 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