Module: Jets::Job::Helpers::SqsEvent
- Included in:
- Base
- Defined in:
- lib/jets/job/helpers/sqs_event.rb
Instance Method Summary collapse
-
#sqs_event_payload ⇒ Object
Deprecated methods below.
- #sqs_events ⇒ Object (also: #sqs_event_payloads)
- #sqs_events? ⇒ Boolean (also: #sqs_event_payloads?)
Instance Method Details
#sqs_event_payload ⇒ Object
Deprecated methods below
19 20 21 22 23 24 |
# File 'lib/jets/job/helpers/sqs_event.rb', line 19 def sqs_event_payload puts "WARN: sqs_event_payload is deprecated".color(:yellow) puts "It can possibly drop events when they come in extremely fast." puts "Use sqs_events instead" sqs_events.first end |
#sqs_events ⇒ Object Also known as: sqs_event_payloads
3 4 5 6 7 8 9 10 |
# File 'lib/jets/job/helpers/sqs_event.rb', line 3 def sqs_events records = event["Records"] return [] unless records records.map do |record| = record["body"] ActiveSupport::HashWithIndifferentAccess.new(JSON.load()) end end |
#sqs_events? ⇒ Boolean Also known as: sqs_event_payloads?
13 14 15 |
# File 'lib/jets/job/helpers/sqs_event.rb', line 13 def sqs_events? event["Records"]&.any? { |r| r.dig("body") } end |