Module: Jets::Job::Helpers::SqsEventHelper

Included in:
Base
Defined in:
lib/jets/job/helpers/sqs_event_helper.rb

Instance Method Summary collapse

Instance Method Details

#sqs_event_payloadObject



3
4
5
6
# File 'lib/jets/job/helpers/sqs_event_helper.rb', line 3

def sqs_event_payload
   message = event&.dig("Records", 0, "body")
   @sqs_event_payload ||= ActiveSupport::HashWithIndifferentAccess.new(JSON.parse(message))
end