Method: Pheme::QueuePoller#parse_message_attributes

Defined in:
lib/pheme/queue_poller.rb

#parse_message_attributes(queue_message) ⇒ Object 



110
111
112
113
114
115
116
117
118
 
# File 'lib/pheme/queue_poller.rb', line 110

def parse_message_attributes(queue_message)
  message_body = JSON.parse(queue_message.body)
  message_attributes = {}
  message_body['MessageAttributes']&.each do |key, value|
    message_attributes[key.to_sym] = coerce_message_attribute(value)
  end

  message_attributes
end