Sha256: f1316d5900442189ea1aa5cdc20fcc241623c2e9c0657efc84f298adb330c1e9

Contents?: true

Size: 255 Bytes

Versions: 28

Compression:

Stored size: 255 Bytes

Contents

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

Version data entries

28 entries across 28 versions & 1 rubygems

Version Path
jets-4.0.12 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.11 lib/jets/job/helpers/sqs_event_helper.rb
jets-5.0.6 lib/jets/job/helpers/sqs_event_helper.rb
jets-5.0.5 lib/jets/job/helpers/sqs_event_helper.rb
jets-5.0.4 lib/jets/job/helpers/sqs_event_helper.rb
jets-5.0.3 lib/jets/job/helpers/sqs_event_helper.rb
jets-5.0.2 lib/jets/job/helpers/sqs_event_helper.rb
jets-5.0.1 lib/jets/job/helpers/sqs_event_helper.rb
jets-5.0.0 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.10 lib/jets/job/helpers/sqs_event_helper.rb
jets-5.0.0.beta1 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.9 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.8 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.7 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.6 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.5 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.4 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.3 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.2 lib/jets/job/helpers/sqs_event_helper.rb
jets-4.0.1 lib/jets/job/helpers/sqs_event_helper.rb