lib/propono/components/sqs_message.rb in propono-1.3.0 vs lib/propono/components/sqs_message.rb in propono-1.4.0
- old
+ new
@@ -7,10 +7,10 @@
raw_body = raw_message["Body"]
@raw_body_json = JSON.parse(raw_body)
body = JSON.parse(@raw_body_json["Message"])
@raw_message = raw_message
- @context = body.symbolize_keys
+ @context = Propono::Utils.symbolize_keys body
@failure_count = context[:num_failures] || 0
@message = context.delete(:message)
@receipt_handle = raw_message["receipt_handle"]
end